Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/hazelcast/hazelcast
/ functions
Functions
147,315 in github.com/hazelcast/hazelcast
⨍
Functions
147,315
◇
Types & classes
15,944
↓ 6 callers
Method
fastLongMix
Hash function based on Knuth's multiplicative method. This version is faster than using Murmur hash but provides acceptable behavior. @param k the lo
hazelcast/src/main/java/com/hazelcast/internal/util/HashUtil.java:292
↓ 6 callers
Method
field
(String name, QueryDataType type, String externalName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/MetadataJsonResolverTest.java:121
↓ 6 callers
Method
field
(String name, QueryDataType type, String externalName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataJsonResolverTest.java:121
↓ 6 callers
Method
fileToUrl
(@Nonnull File file)
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1098
↓ 6 callers
Method
filesBuilder
Returns a builder object that offers a step-by-step fluent API to build a custom file sink for the Pipeline API. See javadoc of methods in {@link File
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sinks.java:1253
↓ 6 callers
Method
fillIMapAndGetData
(IMap<Integer, String> map, final int count)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlSelectTest.java:45
↓ 6 callers
Method
fillMap
(IMap<String, String> map, int partitionId, int count, String value)
hazelcast/src/test/java/com/hazelcast/map/AbstractMapQueryPartitionIteratorTest.java:215
↓ 6 callers
Method
fillMap
(IMap<String, String> map, int partitionId, int count, String value)
hazelcast/src/test/java/com/hazelcast/map/AbstractMapQueryPartitionIterableTest.java:202
↓ 6 callers
Method
filter
(String className)
hazelcast/src/main/java/com/hazelcast/internal/serialization/ReflectionClassNameFilter.java:60
↓ 6 callers
Method
filter
Produces a filtered entry set by utilizing the indexes available while executing the query in the given query context. <p> The query engine assumes th
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/IndexAwarePredicate.java:67
↓ 6 callers
Method
findCardinalityEstimatorConfig
Finds existing Cardinality Estimator config. @param name name of the config @return Cardinality Estimator config or {@code null} when requested Cardi
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:166
↓ 6 callers
Method
findLoadedClass
(String name)
hazelcast/src/main/java/com/hazelcast/internal/usercodedeployment/impl/ClassLocator.java:275
↓ 6 callers
Method
finishDirectory
(Future<Void> jobFuture, File ... files)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamFilesP_integrationTest.java:291
↓ 6 callers
Method
finishDirectory
(File... files)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadFilesPTest.java:217
↓ 6 callers
Method
fixPortBinding
(GenericContainer<?> container, Integer defaultPort)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:219
↓ 6 callers
Method
floorCeil
(Object floorVal, Object ceilVal)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/FloorCeilFunctionIntegrationTest.java:148
↓ 6 callers
Method
formatJob
(Job job)
hazelcast/src/main/java/com/hazelcast/client/console/HazelcastCommandLine.java:586
↓ 6 callers
Method
fromMap
(Map<String, String> map)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/util/PropertiesUtil.java:31
↓ 6 callers
Method
generateRandomUniverse
(long seed, int count, long range)
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:362
↓ 6 callers
Method
get
()
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/executor/ExecutorSplitBrainProtectionWriteTest.java:642
↓ 6 callers
Method
get
()
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/executor/ExecutorSplitBrainProtectionWriteTest.java:677
↓ 6 callers
Method
get
()
hazelcast/src/main/java/com/hazelcast/spi/impl/DeserializingCompletableFuture.java:80
↓ 6 callers
Method
get
Return the entry for the scheduled key. @param key the scheduled key @return the scheduled execution, in case of {@link ScheduleType#FOR_EACH} a rando
hazelcast/src/main/java/com/hazelcast/internal/util/scheduler/EntryTaskScheduler.java:64
↓ 6 callers
Method
getAccessControlServiceConfig
Returns configured {@link AccessControlServiceConfig}. @see #setAccessControlServiceConfig(AccessControlServiceConfig) @return configured {@link Acce
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:148
↓ 6 callers
Method
getAddedEventCount
()
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheListenerTest.java:294
↓ 6 callers
Method
getAddress
Returns the Vault server address. @return the Vault server address
hazelcast/src/main/java/com/hazelcast/config/VaultSecureStoreConfig.java:81
↓ 6 callers
Method
getAddressProvider
()
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/CandidateClusterContext.java:64
↓ 6 callers
Method
getAddresses
(Collection<HazelcastInstance> instances)
hazelcast/src/test/java/com/hazelcast/test/PacketFiltersUtil.java:117
↓ 6 callers
Method
getAll
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/publisher/MapPublisherRegistry.java:58
↓ 6 callers
Method
getAndInc
()
hazelcast/src/main/java/com/hazelcast/internal/util/MutableLong.java:43
↓ 6 callers
Method
getAndRemoveAsync
Asynchronously removes the entry for a key and returns the previously assigned value or null if no value was assigned. <p> If the cache is configured
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:475
↓ 6 callers
Method
getAppendRequestBackoffTimeoutInMillis
()
hazelcast/src/main/java/com/hazelcast/config/cp/RaftAlgorithmConfig.java:220
↓ 6 callers
Method
getAppendRequestMaxEntryCount
()
hazelcast/src/main/java/com/hazelcast/config/cp/RaftAlgorithmConfig.java:177
↓ 6 callers
Method
getArrayOfNullable
(@Nonnull String fieldName, Reader<T> reader, IntFunction<T[]> construc
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:767
↓ 6 callers
Method
getArrayOfPrimitive
(@Nonnull String fieldName, Reader<T> reader, FieldKind primitiveKind, F
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:539
↓ 6 callers
Method
getAsyncBackupCount
Gets the number of asynchronous backups for this {@link com.hazelcast.cache.ICache}. @return the number of asynchronous backups for this {@link com.h
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:331
↓ 6 callers
Method
getAttributeValue
(String attributeName)
hazelcast/src/main/java/com/hazelcast/query/impl/QueryableEntry.java:60
↓ 6 callers
Method
getAverageRemoveTime
The mean time to execute removes. @return the mean time in microseconds to execute removes
hazelcast/src/main/java/com/hazelcast/cache/CacheStatistics.java:199
↓ 6 callers
Method
getAwsConfig
Returns the current {@link AwsConfig}. @return ClientAwsConfig @see #setAwsConfig(AwsConfig)
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:348
↓ 6 callers
Method
getBackupCount
Gets the number of synchronous backups for this {@link com.hazelcast.cache.ICache}. @return the number of synchronous backups (backupCount) for this
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:303
↓ 6 callers
Method
getBackupCount
Get the number of synchronous backups for this queue. @return the synchronous backup count
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:163
↓ 6 callers
Method
getBackupCount
Returns backup count. Last {@code backupCount} backups will be kept. @return backupCount
hazelcast/src/main/java/com/hazelcast/config/DynamicConfigurationConfig.java:96
↓ 6 callers
Method
getBackupCount
Gets the number of synchronous backups. @return number of synchronous backups
hazelcast/src/main/java/com/hazelcast/config/CardinalityEstimatorConfig.java:160
↓ 6 callers
Method
getBackupInstance
(HazelcastInstance[] instances, int partitionId, int replicaIndex)
hazelcast/src/test/java/com/hazelcast/test/Accessors.java:155
↓ 6 callers
Method
getBatchSize
Returns the maximum batch size that can be sent to target cluster. @return the maximum size of a WAN event batch
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:199
↓ 6 callers
Method
getBindings
(int scope)
hazelcast/src/main/java/com/hazelcast/osgi/impl/OSGiScriptEngine.java:84
↓ 6 callers
Method
getBooleanVolatile
Reads the boolean value as volatile from given object by its offset. @param address address to access @return the boolean value that was read
hazelcast/src/main/java/com/hazelcast/internal/memory/ConcurrentMemoryAccessor.java:32
↓ 6 callers
Method
getBufferSize
Gets the SO_SNDBUF and SO_RCVBUF option value @return bufferSize KB value
hazelcast/src/main/java/com/hazelcast/client/config/SocketOptions.java:149
↓ 6 callers
Method
getById
(int id)
hazelcast/src/main/java/com/hazelcast/jet/core/JobStatus.java:85
↓ 6 callers
Method
getByteVolatile
Reads the byte value as volatile from given object by its offset. @param address address to access @return the byte value that was read
hazelcast/src/main/java/com/hazelcast/internal/memory/ConcurrentMemoryAccessor.java:48
↓ 6 callers
Method
getCPMemberPriority
Returns the CP member priority. @return the CP member priority
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:607
↓ 6 callers
Method
getCPSubsystemManagementService
Returns the {@link CPSubsystemManagementService} of this Hazelcast instance. {@link CPSubsystemManagementService} offers APIs for managing CP members
hazelcast/src/main/java/com/hazelcast/cp/CPSubsystem.java:557
↓ 6 callers
Method
getCacheConfig
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigTest.java:864
↓ 6 callers
Method
getCacheEntryEventFilterFactory
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheHazelcastInstanceAwareTest.java:522
↓ 6 callers
Method
getCacheEntryListenerFactory
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheHazelcastInstanceAwareTest.java:512
↓ 6 callers
Method
getCacheService
(HazelcastInstance member)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheConfigPropagationTest.java:162
↓ 6 callers
Method
getCapacity
Gets the capacity of the event journal. The capacity is the total number of items that the event journal can hold at any moment. The actual number of
hazelcast/src/main/java/com/hazelcast/config/EventJournalConfig.java:85
↓ 6 callers
Method
getCity
()
hazelcast/src/test/java/com/hazelcast/query/SampleTestObjects.java:325
↓ 6 callers
Method
getClassName
()
hazelcast/src/main/java/com/hazelcast/config/GlobalSerializerConfig.java:40
↓ 6 callers
Method
getClient
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientProxy.java:84
↓ 6 callers
Method
getClientJetService
()
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/execute/JobExecuteClientFailureTest.java:232
↓ 6 callers
Method
getClusterConnectTimeoutMillis
Timeout value in milliseconds for the client to give up to connect to the current cluster Depending on FailoverConfig, a client can shut down or start
hazelcast/src/main/java/com/hazelcast/client/config/ConnectionRetryConfig.java:132
↓ 6 callers
Method
getClusterVersion
Returns the cluster version, which may be {@link Version#UNKNOWN}.
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:116
↓ 6 callers
Method
getClusterViewListenerService
()
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEngine.java:91
↓ 6 callers
Method
getCode
()
hazelcast/src/main/java/com/hazelcast/internal/management/events/EventMetadata.java:65
↓ 6 callers
Method
getCode
()
hazelcast/src/main/java/com/hazelcast/config/RestEndpointGroup.java:105
↓ 6 callers
Method
getCommitEvents
()
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestAbstractMigrationAwareService.java:100
↓ 6 callers
Method
getCommitIndexAdvanceCountToSnapshot
()
hazelcast/src/main/java/com/hazelcast/config/cp/RaftAlgorithmConfig.java:188
↓ 6 callers
Method
getCompletedMigrationsCopy
Returns a copy of the list of completed migrations. Runs under the partition service lock.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:149
↓ 6 callers
Method
getConfigByTag
Gets the {@link AliasedDiscoveryConfig} from {@code config} by {@code tag}.
hazelcast/src/main/java/com/hazelcast/internal/config/AliasedDiscoveryConfigUtils.java:134
↓ 6 callers
Method
getConfigWithService
(Object service, String serviceName)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembershipUpdateTest.java:893
↓ 6 callers
Method
getConnectionFactory
()
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsSinkIntegrationTest.java:236
↓ 6 callers
Method
getConnectionRegistrations
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerRegistration.java:45
↓ 6 callers
Method
getConnections
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManager.java:107
↓ 6 callers
Method
getContent
@return The content of the token.
hazelcast/src/main/java/com/hazelcast/client/impl/TpcToken.java:43
↓ 6 callers
Method
getContext
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientProxy.java:67
↓ 6 callers
Method
getCooperativeThreadCount
()
hazelcast/src/main/java/com/hazelcast/jet/impl/config/DelegatingInstanceConfig.java:44
↓ 6 callers
Method
getCpSubsystem
()
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpPostCommandProcessor.java:613
↓ 6 callers
Method
getCurrent
Returns the current attribute path part. The returned string is either the name of the current attribute or the string representation of an array inde
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonPathCursor.java:119
↓ 6 callers
Method
getCurrentReplicas
Returns the total number of current replicas. If the context is empty, returns {@value ClusterTopologyIntentTracker#UNKNOWN}. @see StatefulSetInfo#cu
hazelcast/src/test/java/com/hazelcast/kubernetes/RuntimeContextTest.java:167
↓ 6 callers
Method
getCurrentWatermark
Called to get the current watermark. The watermark may advance based just on the passage of time.
hazelcast/src/main/java/com/hazelcast/jet/core/WatermarkPolicy.java:56
↓ 6 callers
Method
getDataConnectionName
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/MapSinkConfiguration.java:51
↓ 6 callers
Method
getDataPersistenceConfig
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/CacheConfigHolder.java:195
↓ 6 callers
Method
getDatabaseName
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/H2DatabaseProvider.java:79
↓ 6 callers
Method
getDefault
(Config c)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:328
↓ 6 callers
Method
getDelaySeconds
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorInfo.java:126
↓ 6 callers
Method
getDelegateFromProxyClass
(Object arg)
hazelcast/src/test/java/com/hazelcast/test/starter/ReflectionUtils.java:179
↓ 6 callers
Method
getDiagnosticsConfig
Returns registered diagnostics configuration. @return registered diagnostics configuration
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:422
↓ 6 callers
Method
getDictionaryId
(String word)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCompressor.java:260
↓ 6 callers
Method
getDigest
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:215
↓ 6 callers
Method
getDistributedObjectName
Convenience method to obtain the name of Hazelcast distributed object corresponding to the cache identified by the given {@code cacheName}, assuming {
hazelcast/src/main/java/com/hazelcast/cache/CacheUtil.java:93
↓ 6 callers
Method
getDriverType
()
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceTestConfiguration.java:85
↓ 6 callers
Method
getDummyBean
()
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/cache/JCacheCacheWriter.java:82
↓ 6 callers
Method
getEntryListenerConfigs
()
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:428
↓ 6 callers
Method
getEntryProcessor
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:243
↓ 6 callers
Method
getEvents
()
hazelcast/src/test/java/com/hazelcast/partition/PartitionLostListenerStressTest.java:159
↓ 6 callers
Method
getExecutorName
Used when this step is an offload-step, otherwise not used. @param state the state object @return name of the executor to run this step(valid if this
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/Step.java:70
↓ 6 callers
Method
getExistingMapContainer
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:110
↓ 6 callers
Method
getExistingRecordStore
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/PartitionContainer.java:47
↓ 6 callers
Method
getExpirationPolicy
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:684
← previous
next →
9,401–9,500 of 147,315, ranked by callers