MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodrunPartitionOperation
(PartitionMigrationEvent event, String type, int replicaIndex)
hazelcast/src/test/java/com/hazelcast/internal/partition/MigrationAwareServiceEventTest.java:184
↓ 2 callersMethodrunPingTask
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 callersMethodrunProcessorWithCoLocation
(List<Shard> shards)
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/impl/ElasticSourcePTest.java:100
↓ 2 callersMethodrunQuery
(MySQLContainer<?> container, String query)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/MySQLTestUtils.java:31
↓ 2 callersMethodrunQueryNTimes
(int queryCount, IMap<String, Employee> map)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryIndexingTest.java:135
↓ 2 callersMethodrunStepInternal
(State state)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/EntryOpSteps.java:129
↓ 2 callersMethodrunStepWithState
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 callersMethodrunTest
(ICache<Integer, Integer> icacheOnClient, NearCacheConfig.LocalUpdatePolicy lo
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheCacheOnUpdateTest.java:89
↓ 2 callersMethodrunTest
(NearCacheTestContext<KeySerializationCountingData, ValueSerializationCountingData, ?, ?> context,
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheSerializationCountTest.java:201
↓ 2 callersMethodrunTestFetchSize
(Properties properties, int fetchSize)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadJdbcPPropertiesTest.java:93
↓ 2 callersMethodrunUsingGlobalIndexSafely
(Predicate predicate, MapContainer mapContainer,
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryRunner.java:264
↓ 2 callersMethodrunWithClassLoader
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 callersMethodrunWithNamespaceAwareness
(String mapName, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapEventPublishingService.java:140
↓ 2 callersMethods3Client
(String endpointURL)
extensions/s3/src/test/java/com/hazelcast/jet/s3/S3MockTest.java:275
↓ 2 callersMethodsample
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 callersMethodsample
(OperationRunner[] runners, ConcurrentItemCounter<String> samples)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/OperationThreadSamplerPlugin.java:168
↓ 2 callersMethodsampleFloats
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:68
↓ 2 callersMethodsamplePersons
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:108
↓ 2 callersMethodsampleRunnable
(Runnable runnable)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/EventQueuePlugin.java:215
↓ 2 callersMethodsanitize
(String s)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoP.java:428
↓ 2 callersMethodsanitize
(String s)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/WriteKafkaP.java:463
↓ 2 callersMethodsanitize
(String s, int width)
hazelcast/src/main/java/com/hazelcast/client/console/SqlConsole.java:450
↓ 2 callersMethodsanitizeScalar
(Object input)
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:119
↓ 2 callersMethodsanitizeValueWithWildcards
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 callersMethodsaveIndex
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 callersMethodsaveInfoAboutCurrentLoaderThread
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapClassLoaderTest.java:103
↓ 2 callersMethodsaveSnapshot
(StreamKafkaP streamKafkaP, TestOutbox outbox)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:937
↓ 2 callersMethodscan
(long nowNanos, long nowMillis, OperationRunner[] operationRunners, CurrentOperation
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetector.java:156
↓ 2 callersMethodscan
(OperationRunner[] runners, LiveOperations result)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationExecutorImpl.java:296
↓ 2 callersMethodscan
(DiagnosticsLogWriter writer, TcpServerConnection connection, boolean priority)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/OverloadedConnectionsPlugin.java:143
↓ 2 callersMethodschedule
()
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/StoreWorker.java:112
↓ 2 callersMethodschedule
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 callersMethodscheduleClusterVersionAutoUpgrade
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 callersMethodscheduleEviction
(Data key, int version, long leaseTime)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockStoreImpl.java:227
↓ 2 callersMethodscheduleJobTimeout
(final long jobId, final long timeout)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1569
↓ 2 callersMethodscheduleMetricsCollectorIfNeeded
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsService.java:132
↓ 2 callersMethodscheduleMigration
Schedules a migration by adding it to the migration queue.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:164
↓ 2 callersMethodscheduleMigrationIfNeeded
(LoadTracker loadTracker)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/iobalancer/IOBalancer.java:154
↓ 2 callersMethodscheduleNewExecution
(long now)
hazelcast/src/main/java/com/hazelcast/internal/util/scheduler/CoalescingDelayedTrigger.java:93
↓ 2 callersMethodscheduleNextRun
Reruns this operation with next {@link #runStage}
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PromotionCommitOperation.java:263
↓ 2 callersMethodscheduleNextRun
()
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/RepairingTask.java:166
↓ 2 callersMethodscheduleOnMember
(@Nonnull Runnable command, @Nonnull Member member,
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledExecutorProxy.java:141
↓ 2 callersMethodscheduleOnMembersAtFixedRate
(@Nonnull Runnable command, @Nonn
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledExecutorProxy.java:272
↓ 2 callersMethodscheduleOnMembersAtFixedRate
(@Nonnull Runnable command, @Nonn
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceProxy.java:317
↓ 2 callersMethodscheduleRegisteredPlugins
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:806
↓ 2 callersMethodscheduledExec
(int index, SplitBrainProtectionOn splitBrainProtectionOn, String postfix)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/AbstractSplitBrainProtectionTest.java:352
↓ 2 callersMethodschema
(QueryParameterMetadata parameterMetadata)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/JoinPhysicalRel.java:49
↓ 2 callersMethodschema
(QueryParameterMetadata parameterMetadata)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/LimitPhysicalRel.java:52
↓ 2 callersMethodscrollKeepAlive
()
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/ElasticSourceConfiguration.java:97
↓ 2 callersMethodsearchRequestFn
()
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/ElasticSourceConfiguration.java:75
↓ 2 callersMethodsecureElasticClientSupplier
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/ElasticSupport.java:78
↓ 2 callersMethodselect
(Member member)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/executor/ExecutorSplitBrainProtectionWriteTest.java:612
↓ 2 callersMethodselectEntriesToStore
(RecordStore recordStore, List<DelayedEntry> entries, long highestStoreTime)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/StoreWorker.java:209
↓ 2 callersMethodselectKeysToLoad
(int rangeStart, int rangeEnd)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/LoadAllTest.java:223
↓ 2 callersMethodsend
(DistributedObjectEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AddDistributedObjectListenerMessageTask.java:101
↓ 2 callersMethodsend
(ItemEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/queue/QueueAddListenerMessageTask.java:65
↓ 2 callersMethodsend
(ItemEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/list/ListAddListenerMessageTask.java:79
↓ 2 callersMethodsend
(ItemEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/set/SetAddListenerMessageTask.java:82
↓ 2 callersMethodsend
(ServerConnectionManager connectionManager, Address target, Response response)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OutboundResponseHandler.java:109
↓ 2 callersMethodsend204
Prepares a {@link HttpURLConnection#HTTP_NO_CONTENT} response.
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommand.java:78
↓ 2 callersMethodsendBackups
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 callersMethodsendBackupsAndResponse
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:320
↓ 2 callersMethodsendBatch
(String dataStructureName, List<Integer> memberPartitions, List<MergingItem>[] entriesPerPartition,
hazelcast/src/main/java/com/hazelcast/spi/impl/merge/AbstractMergeRunnable.java:237
↓ 2 callersMethodsendBatch
(int partitionId, String name, SplitBrainMergePolicy<Collection<Object>, MultiM
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapService.java:643
↓ 2 callersMethodsendBatch
(int partitionId, String name, List<ScheduledExecutorMergeTypes> mergingEntries,
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/DistributedScheduledExecutorService.java:400
↓ 2 callersMethodsendClientEvent
(ClientEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointManagerImpl.java:130
↓ 2 callersMethodsendDemoteResponseOperation
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 callersMethodsendExecuteRequest
(ClientConnection connection, QueryId queryId)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlClientExecuteCloseRaceTest.java:155
↓ 2 callersMethodsendExplicitSuspicionTrigger
(Address triggerTo, MembersViewMetadata endpointMembersViewMetadata)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:254
↓ 2 callersMethodsendFinalizeJoinOp
(MemberInfo member, UUID thisUuid, MembersView newMembersView, OnJoinOp pr
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:850
↓ 2 callersMethodsendHeartbeat
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 callersMethodsendImmediately
(Invalidation invalidation, int orderKey)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/Invalidator.java:121
↓ 2 callersMethodsendInvalidation
(Invalidation invalidation)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/AbstractBaseNearCacheInvalidationListener.java:52
↓ 2 callersMethodsendJoinDatagram
(Serializable object, boolean useBigEndian)
hazelcast/src/test/java/com/hazelcast/cluster/MulticastDeserializationTest.java:131
↓ 2 callersMethodsendKeys
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 callersMethodsendMembershipEventNotifications
(MemberImpl member, Set<Member> members, final boolean added)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:853
↓ 2 callersMethodsendMembershipEvents
(Collection<MemberImpl> currentMembers, Collection<MemberImpl> newMembers, boolean sortMembers)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:822
↓ 2 callersMethodsendMessageWithOrderKey
(ClientMessage clientMessage, Object orderKey)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/AbstractBaseNearCacheInvalidationListener.java:48
↓ 2 callersMethodsendMessages
(ConnectionFactory cf, String destinationName, boolean isQueue, int count)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsTestUtil.java:37
↓ 2 callersMethodsendOperationsOnPartitionThread
(Collection<Operation> operations, Collection<ChunkSupplier>
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PartitionReplicaSyncRequestOffloadable.java:177
↓ 2 callersMethodsendPartitionLostEvent
(int partitionId, int lostReplicaIndex)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionEventManager.java:193
↓ 2 callersMethodsendPing
(ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/HeartbeatManager.java:132
↓ 2 callersMethodsendReplicationOperation
(boolean isRemove)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/operation/AbstractReplicatedMapOperation.java:41
↓ 2 callersMethodsendResponse
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 callersMethodsendResponse
(Operation op, Object response)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperation.java:561
↓ 2 callersMethodsendSingleBackup
(BackupAwareOperation backupAwareOp, InternalPartition partition, long[] repl
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationBackupHandler.java:200
↓ 2 callersMethodsendStateToCluster
()
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl.java:946
↓ 2 callersMethodsendUpdateCallerOperation
(boolean isRemove)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/operation/AbstractReplicatedMapOperation.java:74
↓ 2 callersMethodsendWatchRequest
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 callersMethodsequenceSource
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 callersMethodsequenceValue
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 callersMethodserializationService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobProxy.java:211
↓ 2 callersMethodserialize
(Object original)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:483
↓ 2 callersMethodserialize
(DatumWriter<T> datumWriter, T data)
extensions/avro/src/main/java/com/hazelcast/jet/avro/impl/AvroSerializerHooks.java:60
↓ 2 callersMethodserializerForClass
(Class type, boolean includeSchema)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/AbstractSerializationService.java:594
↓ 2 callersMethodserviceLbHost
(ServicePort port, String hostname)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:462
↓ 2 callersMethodset
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 callersMethodset
(Object o)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ProxyManager.java:450
↓ 2 callersMethodset
(K key, V value)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:44
↓ 2 callersMethodset
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
← previousnext →20,701–20,800 of 147,315, ranked by callers