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
↓ 2 callers
Method
runPartitionOperation
(PartitionMigrationEvent event, String type, int replicaIndex)
hazelcast/src/test/java/com/hazelcast/internal/partition/MigrationAwareServiceEventTest.java:184
↓ 2 callers
Method
runPingTask
Tries to ping the {@code member} and removes the member if it is unreachable. @param member the member for which we need to determine reachability
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterHeartbeatManager.java:607
↓ 2 callers
Method
runProcessorWithCoLocation
(List<Shard> shards)
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/impl/ElasticSourcePTest.java:100
↓ 2 callers
Method
runQuery
(MySQLContainer<?> container, String query)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/MySQLTestUtils.java:31
↓ 2 callers
Method
runQueryNTimes
(int queryCount, IMap<String, Employee> map)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryIndexingTest.java:135
↓ 2 callers
Method
runStepInternal
(State state)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/EntryOpSteps.java:129
↓ 2 callers
Method
runStepWithState
Runs the supplied step with the supplied state and schedules the next step.
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/StepSupplier.java:177
↓ 2 callers
Method
runTest
(ICache<Integer, Integer> icacheOnClient, NearCacheConfig.LocalUpdatePolicy lo
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheCacheOnUpdateTest.java:89
↓ 2 callers
Method
runTest
(NearCacheTestContext<KeySerializationCountingData, ValueSerializationCountingData, ?, ?> context,
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheSerializationCountTest.java:201
↓ 2 callers
Method
runTestFetchSize
(Properties properties, int fetchSize)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadJdbcPPropertiesTest.java:93
↓ 2 callers
Method
runUsingGlobalIndexSafely
(Predicate predicate, MapContainer mapContainer,
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryRunner.java:264
↓ 2 callers
Method
runWithClassLoader
Runs the passed {@link Callable} within the {@link ClassLoader} context of the passed {@link ClassLoader}, leveraging the {@link com.hazelcast.interna
hazelcast/src/main/java/com/hazelcast/internal/namespace/NamespaceUtil.java:239
↓ 2 callers
Method
runWithNamespaceAwareness
(String mapName, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapEventPublishingService.java:140
↓ 2 callers
Method
s3Client
(String endpointURL)
extensions/s3/src/test/java/com/hazelcast/jet/s3/S3MockTest.java:275
↓ 2 callers
Method
sample
The sample method is used to sample a number of entries (defined by the samples parameter) from the internal data structure. This method should be exe
hazelcast/src/main/java/com/hazelcast/internal/eviction/impl/strategy/sampling/SampleableEvictableStore.java:37
↓ 2 callers
Method
sample
(OperationRunner[] runners, ConcurrentItemCounter<String> samples)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/OperationThreadSamplerPlugin.java:168
↓ 2 callers
Method
sampleFloats
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:68
↓ 2 callers
Method
samplePersons
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:108
↓ 2 callers
Method
sampleRunnable
(Runnable runnable)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/EventQueuePlugin.java:215
↓ 2 callers
Method
sanitize
(String s)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoP.java:428
↓ 2 callers
Method
sanitize
(String s)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/WriteKafkaP.java:463
↓ 2 callers
Method
sanitize
(String s, int width)
hazelcast/src/main/java/com/hazelcast/client/console/SqlConsole.java:450
↓ 2 callers
Method
sanitizeScalar
(Object input)
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:119
↓ 2 callers
Method
sanitizeValueWithWildcards
Sanitizes values in order to replace any regexp-specific char sequences, except for wildcards (' '). First, quotes the input string to escape any rege
hazelcast/src/main/java/com/hazelcast/internal/management/ClientBwListConfigHandler.java:103
↓ 2 callers
Method
saveIndex
Same as {@link #saveIndex} with explicit {@link CachedQueryEntry} arguments for reuse, to avoid excessive litter when adding several entries in batch.
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/DefaultQueryCacheRecordStore.java:154
↓ 2 callers
Method
saveInfoAboutCurrentLoaderThread
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapClassLoaderTest.java:103
↓ 2 callers
Method
saveSnapshot
(StreamKafkaP streamKafkaP, TestOutbox outbox)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:937
↓ 2 callers
Method
scan
(long nowNanos, long nowMillis, OperationRunner[] operationRunners, CurrentOperation
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetector.java:156
↓ 2 callers
Method
scan
(OperationRunner[] runners, LiveOperations result)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationExecutorImpl.java:296
↓ 2 callers
Method
scan
(DiagnosticsLogWriter writer, TcpServerConnection connection, boolean priority)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/OverloadedConnectionsPlugin.java:143
↓ 2 callers
Method
schedule
()
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/StoreWorker.java:112
↓ 2 callers
Method
schedule
Creates and executes a one-shot action that becomes enabled after the given delay. @param command the task to execute @param delay the time from no
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:98
↓ 2 callers
Method
scheduleClusterVersionAutoUpgrade
Cluster version auto upgrade is done asynchronously. Every call of this method creates and schedules a new auto upgrade task.
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:154
↓ 2 callers
Method
scheduleEviction
(Data key, int version, long leaseTime)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockStoreImpl.java:227
↓ 2 callers
Method
scheduleJobTimeout
(final long jobId, final long timeout)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1569
↓ 2 callers
Method
scheduleMetricsCollectorIfNeeded
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsService.java:132
↓ 2 callers
Method
scheduleMigration
Schedules a migration by adding it to the migration queue.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:164
↓ 2 callers
Method
scheduleMigrationIfNeeded
(LoadTracker loadTracker)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/iobalancer/IOBalancer.java:154
↓ 2 callers
Method
scheduleNewExecution
(long now)
hazelcast/src/main/java/com/hazelcast/internal/util/scheduler/CoalescingDelayedTrigger.java:93
↓ 2 callers
Method
scheduleNextRun
Reruns this operation with next {@link #runStage}
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PromotionCommitOperation.java:263
↓ 2 callers
Method
scheduleNextRun
()
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/RepairingTask.java:166
↓ 2 callers
Method
scheduleOnMember
(@Nonnull Runnable command, @Nonnull Member member,
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledExecutorProxy.java:141
↓ 2 callers
Method
scheduleOnMembersAtFixedRate
(@Nonnull Runnable command, @Nonn
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledExecutorProxy.java:272
↓ 2 callers
Method
scheduleOnMembersAtFixedRate
(@Nonnull Runnable command, @Nonn
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceProxy.java:317
↓ 2 callers
Method
scheduleRegisteredPlugins
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:806
↓ 2 callers
Method
scheduledExec
(int index, SplitBrainProtectionOn splitBrainProtectionOn, String postfix)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/AbstractSplitBrainProtectionTest.java:352
↓ 2 callers
Method
schema
(QueryParameterMetadata parameterMetadata)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/JoinPhysicalRel.java:49
↓ 2 callers
Method
schema
(QueryParameterMetadata parameterMetadata)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/LimitPhysicalRel.java:52
↓ 2 callers
Method
scrollKeepAlive
()
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/ElasticSourceConfiguration.java:97
↓ 2 callers
Method
searchRequestFn
()
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/ElasticSourceConfiguration.java:75
↓ 2 callers
Method
secureElasticClientSupplier
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/ElasticSupport.java:78
↓ 2 callers
Method
select
(Member member)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/executor/ExecutorSplitBrainProtectionWriteTest.java:612
↓ 2 callers
Method
selectEntriesToStore
(RecordStore recordStore, List<DelayedEntry> entries, long highestStoreTime)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/StoreWorker.java:209
↓ 2 callers
Method
selectKeysToLoad
(int rangeStart, int rangeEnd)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/LoadAllTest.java:223
↓ 2 callers
Method
send
(DistributedObjectEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AddDistributedObjectListenerMessageTask.java:101
↓ 2 callers
Method
send
(ItemEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/queue/QueueAddListenerMessageTask.java:65
↓ 2 callers
Method
send
(ItemEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/list/ListAddListenerMessageTask.java:79
↓ 2 callers
Method
send
(ItemEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/set/SetAddListenerMessageTask.java:82
↓ 2 callers
Method
send
(ServerConnectionManager connectionManager, Address target, Response response)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OutboundResponseHandler.java:109
↓ 2 callers
Method
send204
Prepares a {@link HttpURLConnection#HTTP_NO_CONTENT} response.
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommand.java:78
↓ 2 callers
Method
sendBackups
Sends the appropriate backups. This call will not wait till the backups have ACK'ed. If this call is made with a none BackupAwareOperation, then 0 is
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationBackupHandler.java:70
↓ 2 callers
Method
sendBackupsAndResponse
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:320
↓ 2 callers
Method
sendBatch
(String dataStructureName, List<Integer> memberPartitions, List<MergingItem>[] entriesPerPartition,
hazelcast/src/main/java/com/hazelcast/spi/impl/merge/AbstractMergeRunnable.java:237
↓ 2 callers
Method
sendBatch
(int partitionId, String name, SplitBrainMergePolicy<Collection<Object>, MultiM
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapService.java:643
↓ 2 callers
Method
sendBatch
(int partitionId, String name, List<ScheduledExecutorMergeTypes> mergingEntries,
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/DistributedScheduledExecutorService.java:400
↓ 2 callers
Method
sendClientEvent
(ClientEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointManagerImpl.java:130
↓ 2 callers
Method
sendDemoteResponseOperation
Sends a {@link DemoteResponseOperation} to the {@code address} or takes a shortcut if demote is local.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:749
↓ 2 callers
Method
sendExecuteRequest
(ClientConnection connection, QueryId queryId)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlClientExecuteCloseRaceTest.java:155
↓ 2 callers
Method
sendExplicitSuspicionTrigger
(Address triggerTo, MembersViewMetadata endpointMembersViewMetadata)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:254
↓ 2 callers
Method
sendFinalizeJoinOp
(MemberInfo member, UUID thisUuid, MembersView newMembersView, OnJoinOp pr
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:850
↓ 2 callers
Method
sendHeartbeat
Send a {@link HeartbeatOp} to the {@code target} @param target target Member
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterHeartbeatManager.java:617
↓ 2 callers
Method
sendImmediately
(Invalidation invalidation, int orderKey)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/Invalidator.java:121
↓ 2 callers
Method
sendInvalidation
(Invalidation invalidation)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/AbstractBaseNearCacheInvalidationListener.java:52
↓ 2 callers
Method
sendJoinDatagram
(Serializable object, boolean useBigEndian)
hazelcast/src/test/java/com/hazelcast/cluster/MulticastDeserializationTest.java:131
↓ 2 callers
Method
sendKeys
Triggers key loading if there is no ongoing key loading task, otherwise does nothing. The actual loading is done on the {@link ExecutionService#MAP_LO
hazelcast/src/main/java/com/hazelcast/map/impl/MapKeyLoader.java:258
↓ 2 callers
Method
sendMembershipEventNotifications
(MemberImpl member, Set<Member> members, final boolean added)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:853
↓ 2 callers
Method
sendMembershipEvents
(Collection<MemberImpl> currentMembers, Collection<MemberImpl> newMembers, boolean sortMembers)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:822
↓ 2 callers
Method
sendMessageWithOrderKey
(ClientMessage clientMessage, Object orderKey)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/AbstractBaseNearCacheInvalidationListener.java:48
↓ 2 callers
Method
sendMessages
(ConnectionFactory cf, String destinationName, boolean isQueue, int count)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsTestUtil.java:37
↓ 2 callers
Method
sendOperationsOnPartitionThread
(Collection<Operation> operations, Collection<ChunkSupplier>
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PartitionReplicaSyncRequestOffloadable.java:177
↓ 2 callers
Method
sendPartitionLostEvent
(int partitionId, int lostReplicaIndex)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionEventManager.java:193
↓ 2 callers
Method
sendPing
(ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/HeartbeatManager.java:132
↓ 2 callers
Method
sendReplicationOperation
(boolean isRemove)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/operation/AbstractReplicatedMapOperation.java:41
↓ 2 callers
Method
sendResponse
Send a synchronization response to the caller replica containing the replication operations to be executed
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PartitionReplicaSyncRequest.java:252
↓ 2 callers
Method
sendResponse
(Operation op, Object response)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperation.java:561
↓ 2 callers
Method
sendSingleBackup
(BackupAwareOperation backupAwareOp, InternalPartition partition, long[] repl
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationBackupHandler.java:200
↓ 2 callers
Method
sendStateToCluster
()
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl.java:946
↓ 2 callers
Method
sendUpdateCallerOperation
(boolean isRemove)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/operation/AbstractReplicatedMapOperation.java:74
↓ 2 callers
Method
sendWatchRequest
Send a watch request. @return a {@link WatchResponse} that can be used to poll for watch events from Kubernetes API server
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:955
↓ 2 callers
Method
sequenceSource
Specifies the source descriptor of the record's sequence. Any changes observed in its value should be interpreted as a reset in the sequence's numeric
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/ChangeRecord.java:88
↓ 2 callers
Method
sequenceValue
Specifies the numeric value part of the record's source sequence. As long as the source sequence doesn't change, the values will be monotonically incr
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/ChangeRecord.java:78
↓ 2 callers
Method
serializationService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobProxy.java:211
↓ 2 callers
Method
serialize
(Object original)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:483
↓ 2 callers
Method
serialize
(DatumWriter<T> datumWriter, T data)
extensions/avro/src/main/java/com/hazelcast/jet/avro/impl/AvroSerializerHooks.java:60
↓ 2 callers
Method
serializerForClass
(Class type, boolean includeSchema)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/AbstractSerializationService.java:594
↓ 2 callers
Method
serviceLbHost
(ServicePort port, String hostname)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:462
↓ 2 callers
Method
set
Sets the option on the underlying socket. @param option the option @param value the value @param <T> the type of the option/value @return this @t
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocketBuilder.java:45
↓ 2 callers
Method
set
(Object o)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ProxyManager.java:450
↓ 2 callers
Method
set
(K key, V value)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:44
↓ 2 callers
Method
set
Set counter of item to value @param item to set the value for @param value a new value
hazelcast/src/main/java/com/hazelcast/internal/util/ItemCounter.java:98
← previous
next →
20,701–20,800 of 147,315, ranked by callers