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
↓ 8 callers
Method
recordNanos
(long durationNanos)
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:141
↓ 8 callers
Method
recordStoreIterator
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CachePartitionSegment.java:68
↓ 8 callers
Method
recover
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXACompatibilityTest.java:165
↓ 8 callers
Method
registerDynamicMetricsProvider
(DynamicMetricsProvider metricsProvider)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:165
↓ 8 callers
Method
registerLocalListener
(String cacheNameWithPrefix, CacheEventListener listener)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:109
↓ 8 callers
Method
registerSerializer
Registers the given serializer for the given class for the scope of the job. It will be accessible to all the code attached to the underlying pipeline
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1152
↓ 8 callers
Method
releaseReadLock
()
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:88
↓ 8 callers
Method
releaseReplicaSyncPermits
Releases the previously acquired permits. @param permitsToRelease number of permits
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionReplicaManager.java:454
↓ 8 callers
Method
remoteSocketAddress
@return the remote address. Returned value could be null.
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:135
↓ 8 callers
Method
remove
(K key)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:82
↓ 8 callers
Method
replicaMigrationCompleted
Called when a partition replica migration is completed successfully. @param event the event for the partition replica migration
hazelcast/src/main/java/com/hazelcast/partition/MigrationListener.java:64
↓ 8 callers
Method
reset
Resets the descriptor instance @return the this instance after reset
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:292
↓ 8 callers
Method
reset
Resets this service back to its initial state. This should represent the same state that the service would be in after a normal startup, including con
hazelcast/src/main/java/com/hazelcast/internal/services/ManagedService.java:49
↓ 8 callers
Method
reset
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/Joiner.java:31
↓ 8 callers
Method
reset
Returns all associated resources of this map-data-store back to the initial state.
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:59
↓ 8 callers
Method
resetInternalMigrationListener
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitTest.java:523
↓ 8 callers
Method
resolveClass
(ObjectStreamClass desc)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:959
↓ 8 callers
Method
resolveClientFailoverConfig
Loads failover configuration using the search logic described in {@link HazelcastClient#newHazelcastFailoverClient()} and builds {@link ClientFailover
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/FailoverClientConfigSupport.java:45
↓ 8 callers
Method
resolveDialect
(JdbcTable table, DagBuildContext context)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlConnector.java:305
↓ 8 callers
Method
restoreProperty
(String sysProp, String previous)
hazelcast/src/test/java/com/hazelcast/internal/eviction/AbstractExpirationManagerTest.java:223
↓ 8 callers
Method
retrieveResult
Retrieves the result with the given taskId @param taskId combination of partitionId and sequence @param <T> the type of the task's result @return
hazelcast/src/main/java/com/hazelcast/durableexecutor/DurableExecutorService.java:104
↓ 8 callers
Method
returnInputBuffer
Returns a BufferObjectDataInput back to the pool. The implementation is free to not return the instance to the pool. In that case this call does not
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/bufferpool/BufferPool.java:66
↓ 8 callers
Method
returnsResponse
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/operations/Backup.java:263
↓ 8 callers
Method
run
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/sink/ShardCountMonitor.java:20
↓ 8 callers
Method
run
Returns {@code true} if this task has successfully run, {@code false} otherwise. @return {@code true} if this task has successfully run. @throws Exce
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/DefaultWriteBehindProcessor.java:379
↓ 8 callers
Method
runMapFullTest
Extensive test which ensures that the {@link QueryResultSizeExceededException} will not be thrown under the configured limit. <p> This test fills the
hazelcast/src/test/java/com/hazelcast/map/MapUnboundedReturnValuesTestSupport.java:79
↓ 8 callers
Method
runProcessor
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/impl/ElasticSourcePTest.java:92
↓ 8 callers
Method
runTest
( JoinRelType joinType, Expression<Boolean> rowProjectorCondition, Express
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/JoinByEquiJoinProcessorTest.java:141
↓ 8 callers
Method
runTest
( JoinRelType joinType, Expression<Boolean> rowProjectorCondition, List<Ex
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/JoinScanProcessorTest.java:153
↓ 8 callers
Method
sampleIntegers
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:50
↓ 8 callers
Method
sampleLongs
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:59
↓ 8 callers
Method
schedule
(IScheduledExecutorService scheduledExecutorService, int name, int taskValue)
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorSplitBrainTest.java:235
↓ 8 callers
Method
scheduleOnAllMembers
Creates and executes a one-shot action that becomes enabled after the given delay on all cluster {@link Member}s. <p> <b>Note:</b> In the event of Me
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:293
↓ 8 callers
Method
secondary
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/Addresses.java:51
↓ 8 callers
Method
selectClassLoaders
(ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/internal/util/ServiceLoader.java:152
↓ 8 callers
Method
selectMembers
(MemberSelector memberSelector)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientExecutorServiceProxy.java:555
↓ 8 callers
Method
selectMembers
(@Nonnull MemberSelector memberSelector)
hazelcast/src/main/java/com/hazelcast/executor/impl/ExecutorServiceProxy.java:628
↓ 8 callers
Method
serialize
(String o)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/StoreSnapshotTaskletTest.java:196
↓ 8 callers
Method
servicePortWithName
(String name, Integer port, Integer targetPort, Integer nodePort)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:505
↓ 8 callers
Method
session
Returns a window definition that aggregates events into session windows. In a session window, the items are grouped into variable size, non-overlappin
hazelcast/src/main/java/com/hazelcast/jet/pipeline/WindowDefinition.java:142
↓ 8 callers
Method
set
Sets the value of the member with the specified name to the JSON representation of the specified <code>int</code> value. If this object does not conta
hazelcast/src/main/java/com/hazelcast/internal/json/JsonObject.java:316
↓ 8 callers
Method
setAcknowledgeType
Sets the strategy for when the target cluster should acknowledge that a WAN event batch has been processed. @param acknowledgeType acknowledge type @
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:280
↓ 8 callers
Method
setAllocatorType
Sets the {@link MemoryAllocatorType} to be used while allocating native memory. @param allocatorType {@code MemoryAllocatorType} @return this {@link
hazelcast/src/main/java/com/hazelcast/config/NativeMemoryConfig.java:171
↓ 8 callers
Method
setAllowOverrideDefaultSerializers
This configuration should be used cautiously. <p> Default serializers are used heavily by the hazelcast internally. If any of the instance in the same
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:545
↓ 8 callers
Method
setBackupCount
Sets the number of synchronous backups. @param backupCount the number of synchronous backups to set @return the updated SemaphoreConfig @throws Illeg
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:198
↓ 8 callers
Method
setBatchMaxDelayMillis
Sets the maximum amount of time in milliseconds to wait before sending a batch of events to target cluster, if {@link #getBatchSize()} of events have
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:233
↓ 8 callers
Method
setBatchSize
Sets the batch size which will be used to determine number of events to be sent in a batch to {@code QueryCache} @param batchSize the batch size @ret
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:222
↓ 8 callers
Method
setCacheManager
Sets relevant {@link HazelcastCacheManager} to client/server. @param cacheManager client or server {@link HazelcastCacheManager}
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheInternal.java:77
↓ 8 callers
Method
setCapacity
Sets the capacity of this memory tier. @param capacity capacity. @return this MemoryTierConfig
hazelcast/src/main/java/com/hazelcast/config/MemoryTierConfig.java:66
↓ 8 callers
Method
setCompactSerializationConfig
@param compactSerializationConfig config for the compact serialization format @return configured {@link com.hazelcast.config.SerializerConfig} for cha
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:572
↓ 8 callers
Method
setConn
Sets the Connection this Packet is send with. <p> This is done on the reading side of the Packet to make it possible to retrieve information about the
hazelcast/src/main/java/com/hazelcast/internal/nio/Packet.java:145
↓ 8 callers
Method
setConnectionType
Sets the type of the connection @param connectionType to be set
hazelcast/src/main/java/com/hazelcast/internal/server/ServerConnection.java:49
↓ 8 callers
Method
setDiscoveryServiceProvider
(DiscoveryServiceProvider discoveryServiceProvider)
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:66
↓ 8 callers
Method
setEfConstruction
Sets the size of the dynamic list search to use during index time. @param efConstruction the size of the dynamic list search. @return this VectorInde
hazelcast/src/main/java/com/hazelcast/config/vector/VectorIndexConfig.java:220
↓ 8 callers
Method
setEmptyQueueTtl
@param emptyQueueTtl set the TTL (time to live) for destroying the Queue (in seconds). <br> Once items have been removed and the Queue has been
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:120
↓ 8 callers
Method
setEnabled
@param enabled the enabled interface to set
hazelcast/src/main/java/com/hazelcast/config/InterfacesConfig.java:42
↓ 8 callers
Method
setEnabled
(boolean enabled)
hazelcast/src/main/java/com/hazelcast/config/AdvancedNetworkConfig.java:224
↓ 8 callers
Method
setEndpoint
Sets the WAN endpoint configuration qualifier. When using pre-3.12 network configuration, its value can be {@code null} and is not taken into account.
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:776
↓ 8 callers
Method
setFeature
(DocumentBuilderFactory dbf, String featureName)
hazelcast/src/main/java/com/hazelcast/internal/util/XmlUtil.java:205
↓ 8 callers
Method
setIfSupported
Sets the option on the underlying socket if that option is supported. @param option the option @param value the value @param <T> the type of the
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocketBuilder.java:64
↓ 8 callers
Method
setIndexConfigs
(List<IndexConfig> indexConfigs)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:581
↓ 8 callers
Method
setInitError
(SupplierEx<? extends Throwable> initError)
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:459
↓ 8 callers
Method
setKeyClassName
(String keyClassName)
hazelcast/src/main/java/com/hazelcast/config/AbstractCacheConfig.java:368
↓ 8 callers
Method
setKeyType
Sets the key type for this {@link com.hazelcast.cache.ICache}. @param keyType the key type to set for this {@link com.hazelcast.cache.ICache} @return
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:207
↓ 8 callers
Method
setLabel
(String label)
hazelcast/src/test/java/com/hazelcast/ringbuffer/RingbufferSplitBrainTest.java:390
↓ 8 callers
Method
setLastUpdateTime
Sets the cache last update time as atomic if the given time is bigger than it. @param time time to set the cache last update time
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheStatisticsImpl.java:254
↓ 8 callers
Method
setLogger
(@Nonnull ILogger logger)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestProcessorContext.java:78
↓ 8 callers
Method
setMasterAddressToJoin
(final Address master)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:630
↓ 8 callers
Method
setMaxConcurrentReplicationTargets
Sets the maximum number of target members that we replicate the CRDT states to in one period. A higher count will lead to states being disseminated mo
hazelcast/src/main/java/com/hazelcast/config/CRDTReplicationConfig.java:90
↓ 8 callers
Method
setMaxDegree
Sets the maximum number of connections allowed per node. @param maxDegree The maximum degree to set. @return this VectorIndexConfig instance
hazelcast/src/main/java/com/hazelcast/config/vector/VectorIndexConfig.java:197
↓ 8 callers
Method
setMinimumClusterSize
(int minimumClusterSize)
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:132
↓ 8 callers
Method
setName
Sets a descriptive name for this transform. @param name the stage name. If {@code null}, the stage will use its default name
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/Transform.java:45
↓ 8 callers
Method
setName
(String name)
hazelcast/src/main/java/com/hazelcast/config/ServerSocketEndpointConfig.java:201
↓ 8 callers
Method
setNativeMemoryConfig
Sets the native memory configuration for this hazelcast instance. The native memory configuration defines how native memory is used and the limits on
hazelcast/src/main/java/com/hazelcast/config/Config.java:2848
↓ 8 callers
Method
setNewValue
(Object newValue)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:161
↓ 8 callers
Method
setNullableBoolean
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:317
↓ 8 callers
Method
setNullableFloat32
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:448
↓ 8 callers
Method
setNullableFloat64
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:474
↓ 8 callers
Method
setNullableInt8
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:343
↓ 8 callers
Method
setOf
(Object... objects)
hazelcast/src/test/java/com/hazelcast/kubernetes/DnsEndpointResolverTest.java:137
↓ 8 callers
Method
setOwnerUuid
(UUID ownerUuid)
hazelcast/src/main/java/com/hazelcast/map/impl/tx/MapTxnOperation.java:35
↓ 8 callers
Method
setPartitionLostListenerConfigs
(List<MapPartitionLostListenerConfig> listenerConfigs)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:564
↓ 8 callers
Method
setPort
Sets the port the Hazelcast member will try to bind on. <p> A valid port value is between 0 and 65535. A port number of 0 will let the system pick up
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:108
↓ 8 callers
Method
setPrefetchCount
Sets how many IDs are pre-fetched on the background when one call to {@link FlakeIdGenerator#newId()} is made. Default is 100. <p> This setting pertai
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:152
↓ 8 callers
Method
setProtectOn
(SplitBrainProtectionOn protectOn)
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:145
↓ 8 callers
Method
setQueueCapacity
Sets the queue capacity of the executor task. 0 means {@code Integer.MAX_VALUE}. @param queueCapacity Queue capacity of the executor task. 0 means {@
hazelcast/src/main/java/com/hazelcast/config/ExecutorConfig.java:139
↓ 8 callers
Method
setQueueFullBehavior
Sets the configured behaviour of this WAN publisher when the WAN queue is full. @param queueFullBehavior the behaviour of this publisher when the WAN
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:395
↓ 8 callers
Method
setRel
(@Nullable PhysicalRel rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/DagBuildContextImpl.java:79
↓ 8 callers
Method
setReplicaCount
Sets the number of replicas on which state for this PN counter will be kept. This number applies in quiescent state, if there are currently membership
hazelcast/src/main/java/com/hazelcast/config/PNCounterConfig.java:132
↓ 8 callers
Method
setReplicationPeriodMillis
Sets the period between two replications of CRDT states in milliseconds. A lower value will increase the speed at which changes are disseminated to ot
hazelcast/src/main/java/com/hazelcast/config/CRDTReplicationConfig.java:63
↓ 8 callers
Method
setResponseTimeoutMillis
Sets the duration in milliseconds for the waiting time before retrying to send the events to target cluster again in case of acknowledgement is not ar
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:257
↓ 8 callers
Method
setRetentionSeconds
Sets the number of seconds the metrics will be retained on the instance. By default, metrics are retained for 5 seconds (that is for one collection of
hazelcast/src/main/java/com/hazelcast/config/MetricsManagementCenterConfig.java:102
↓ 8 callers
Method
setSalt
Sets the salt used for encryption. @param salt the salt
hazelcast/src/main/java/com/hazelcast/config/AbstractSymmetricEncryptionConfig.java:92
↓ 8 callers
Method
setSocketInterceptorConfig
Sets the {@link SocketInterceptorConfig}. The value can be {@code null} if no socket interception is needed. @param socketInterceptorConfig the Socke
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:298
↓ 8 callers
Method
setTable
(Table table)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/DagBuildContextImpl.java:83
↓ 8 callers
Method
setTableWhitelist
Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be
extensions/cdc-postgres/src/main/java/com/hazelcast/jet/cdc/postgres/PostgresCdcSources.java:262
↓ 8 callers
Method
setTailSequence
Sets the tail sequence. The tail sequence cannot be less than {@code headSequence() - 1}. @param tailSequence the new tail sequence @throws IllegalAr
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/Ringbuffer.java:71
↓ 8 callers
Method
setTarget
Provides the designated target member address to which the operation will be sent. <ul> <li> This method is invoked on the implementing ob
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/TargetAware.java:57
↓ 8 callers
Method
setToValueFn
(FunctionEx<? super T, ? extends V> toValueFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/MapSinkConfiguration.java:83
↓ 8 callers
Method
setUseNativeByteOrder
(boolean useNativeByteOrder)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:53
← previous
next →
8,101–8,200 of 147,315, ranked by callers