MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

⨍ Functions 147,315◇ Types & classes 15,944
↓ 2 callersMethodclean
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/PendingInvocationsPlugin.java:101
↓ 2 callersMethodcleanAtomikosLogs
()
hazelcast/src/test/java/com/hazelcast/client/txn/ClientTxnOwnerDisconnectedTest.java:132
↓ 2 callersMethodcleanAtomikosLogs
()
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXATest.java:69
↓ 2 callersMethodcleanAtomikosLogs
()
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXATest.java:63
↓ 2 callersMethodcleanUpCluster
Clean up the cluster and make it ready to run a next test. If we fail to, shut it down so that next tests don't run on a messed-up cluster. @param in
hazelcast/src/test/java/com/hazelcast/jet/core/JetTestSupport.java:349
↓ 2 callersMethodcleanUpOnMigration
Cleans up the container's state if the enclosing partition is migrated off this member. Whether cleanup is needed is decided based on the provided {@c
hazelcast/src/main/java/com/hazelcast/map/impl/PartitionContainer.java:71
↓ 2 callersMethodcleanup
()
hazelcast/src/test/java/com/hazelcast/client/HazelcastClientTest.java:59
↓ 2 callersMethodcleanup
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:444
↓ 2 callersMethodcleanup
Perform cleaning of the JobMetaDataParameterObject
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobUploadStatus.java:102
↓ 2 callersMethodcleanupDiagnosticFiles
(Diagnostics diagnostics)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/AbstractDiagnosticsPluginTest.java:71
↓ 2 callersMethodcleanupForDefaultCacheManagerTest
()
hazelcast/src/test/java/com/hazelcast/cache/CachingProviderTest.java:243
↓ 2 callersMethodcleanupIterator
(UUID iteratorId)
hazelcast/src/main/java/com/hazelcast/internal/iteration/IteratorWithCursorManager.java:79
↓ 2 callersMethodcleanupRecentlyJoinedMemberUuids
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:381
↓ 2 callersMethodclear
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/plan/cache/PlanCache.java:65
↓ 2 callersMethodclear
()
hazelcast/src/test/java/com/hazelcast/client/map/impl/query/ClientBitmapIndexTest.java:237
↓ 2 callersMethodclear
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapTest.java:174
↓ 2 callersMethodclear
()
hazelcast/src/test/java/com/hazelcast/map/impl/query/SingleValueBitmapIndexTest.java:291
↓ 2 callersMethodclear
()
hazelcast/src/test/java/com/hazelcast/map/impl/query/MultiValueBitmapIndexTest.java:233
↓ 2 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1937
↓ 2 callersMethodclear
(String reason)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEngineImpl.java:427
↓ 2 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:683
↓ 2 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockResourceImpl.java:159
↓ 2 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:299
↓ 2 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalIndexPartitionTracker.java:144
↓ 2 callersMethodclear
Clears a value stored at the given index in this storage. @param index the index to clear a value at. @return {@code true} if this storage array is e
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseIntArray.java:1310
↓ 2 callersMethodclearAllNearCaches
Clears all defined {@link NearCache} instances.
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCacheManager.java:80
↓ 2 callersMethodclearCachesHavingLesserBackupCountThan
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:299
↓ 2 callersMethodclearCollectionsHavingLesserBackupCountThan
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/collection/impl/collection/CollectionService.java:175
↓ 2 callersMethodclearEvents
()
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestAbstractMigrationAwareService.java:112
↓ 2 callersMethodclearExpiredItemsInBuffer
(int ordinal)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/processors/StreamToStreamJoinP.java:496
↓ 2 callersMethodclearGlobalIndexes
Only indexed data will be removed, index info will stay.
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/IndexingMutationObserver.java:114
↓ 2 callersMethodclearInternal
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/AbstractBaseReplicatedRecordStore.java:113
↓ 2 callersMethodclearInternalState
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:617
↓ 2 callersMethodclearListeners
()
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheSyncListenerCompleter.java:149
↓ 2 callersMethodclearLockStoresHavingLesserBackupCountThan
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockSupportServiceImpl.java:284
↓ 2 callersMethodclearLostEventsFlag
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/ReadResultSetImpl.java:253
↓ 2 callersMethodclearMBeans
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTestHelper.java:55
↓ 2 callersMethodclearMapsHavingLesserBackupCountThan
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapService.java:399
↓ 2 callersMethodclearMemberSuspicion
(MemberImpl member, String reason)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:519
↓ 2 callersMethodclearPartitionReplica
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/longregister/LongRegisterService.java:136
↓ 2 callersMethodclearPartitionReplica
(int partitionId, int durabilityThreshold)
hazelcast/src/main/java/com/hazelcast/cardinality/impl/CardinalityEstimatorService.java:165
↓ 2 callersMethodclearPartitionReplica
(int partitionId)
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAService.java:163
↓ 2 callersMethodclearPartitionReplicaVersions
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/FinalizeMigrationOperation.java:171
↓ 2 callersMethodclearQueuesHavingLesserBackupCountThan
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueService.java:246
↓ 2 callersMethodclearRecordsOrDestroyStore
(InMemoryFormat inMemoryFormat, boolean destroy)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheRecordStoreTestSupport.java:68
↓ 2 callersMethodclearRingBuffersHavingLesserBackupCountThan
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/durableexecutor/impl/DistributedDurableExecutorService.java:165
↓ 2 callersMethodclearRingbuffersHavingLesserBackupCountThan
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferService.java:288
↓ 2 callersMethodclearServers
()
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:142
↓ 2 callersMethodclearStorage
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:1721
↓ 2 callersMethodclearThreadContext
Cleans up all of the thread context to avoid potential class loader leaks This method should clear all potential context items, not just the ones set
hazelcast/src/main/java/com/hazelcast/spi/tenantcontrol/TenantControl.java:115
↓ 2 callersMethodclient
()
hazelcast/src/main/java/com/hazelcast/internal/config/override/SystemPropertiesConfigParser.java:39
↓ 2 callersMethodclientFn
()
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/ElasticSourceConfiguration.java:70
↓ 2 callersMethodclientNotAllowedInCluster
Called after an {@link #attemptingToConnectToAddress(Address)} event if the client gets rejected due to a client filtering rule (see <a href="https://
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListener.java:105
↓ 2 callersMethodclientRcvBuf
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/UnifiedProtocolDecoder.java:198
↓ 2 callersMethodclientSndBuf
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/UnifiedProtocolEncoder.java:168
↓ 2 callersMethodclientSupplier
()
extensions/s3/src/test/java/com/hazelcast/jet/s3/S3MockTest.java:252
↓ 2 callersMethodcloneAndReset
Clone and reset the supplied operation. @param op the operation to clone and reset. @param serializationService the serialization service to use for
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationAccessor.java:91
↓ 2 callersMethodcloneKey
(byte[] key)
hazelcast/src/main/java/com/hazelcast/config/SymmetricEncryptionConfig.java:76
↓ 2 callersMethodcloneThroughJson
(WanCustomPublisherConfig expected)
hazelcast/src/test/java/com/hazelcast/internal/management/dto/WanCustomPublisherConfigDTOTest.java:65
↓ 2 callersMethodcloneThroughJson
(DiscoveryStrategyConfig expected)
hazelcast/src/test/java/com/hazelcast/internal/management/dto/DiscoveryStrategyConfigDTOTest.java:64
↓ 2 callersMethodcloneThroughJson
(WanBatchPublisherConfig expected)
hazelcast/src/test/java/com/hazelcast/internal/management/dto/WanBatchPublisherConfigDTOTest.java:99
↓ 2 callersMethodcloneThroughJson
(DiscoveryConfig expected)
hazelcast/src/test/java/com/hazelcast/internal/management/dto/DiscoveryConfigDTOTest.java:59
↓ 2 callersMethodcloneThroughJson
(WanSyncConfig expected)
hazelcast/src/test/java/com/hazelcast/internal/management/dto/WanSyncConfigDTOTest.java:57
↓ 2 callersMethodcloneThroughJson
(AliasedDiscoveryConfig expected)
hazelcast/src/test/java/com/hazelcast/internal/management/dto/AliasedDiscoveryConfigDTOTest.java:67
↓ 2 callersMethodcloneThroughJson
(WanConsumerConfig expected)
hazelcast/src/test/java/com/hazelcast/internal/management/dto/WanConsumerConfigDTOTest.java:65
↓ 2 callersMethodclose
(boolean error, XAResource... xaResource)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXATest.java:261
↓ 2 callersMethodclose
(boolean error, XAResource... xaResource)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXATest.java:262
↓ 2 callersMethodclose
(Connection connection)
hazelcast/src/test/java/com/hazelcast/dataconnection/impl/JdbcDataConnectionTest.java:82
↓ 2 callersMethodclose
()
hazelcast/src/main/java/com/hazelcast/client/cache/HazelcastClientCachingProvider.java:91
↓ 2 callersMethodclose
Closes the result, releasing all the resources. @param exception exception that caused the close operation or {@code null} if the query is closed due
hazelcast/src/main/java/com/hazelcast/sql/impl/AbstractSqlResult.java:52
↓ 2 callersMethodclose
(Connection conn, String reason)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:463
↓ 2 callersMethodclose
Called after the execution has finished on this member - successfully or not. The execution might still be running on other members. This method will
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorSupplier.java:99
↓ 2 callersMethodclose
Closes the buffer, signaling that all items have been emitted. Only {@linkplain #batch} sources are allowed to call this method. @throws JetException
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SourceBuilder.java:86
↓ 2 callersMethodclose0
(boolean destroy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:591
↓ 2 callersMethodclose0
(boolean destroy)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:1162
↓ 2 callersMethodclose0
(QueryClientState clientCursor)
hazelcast/src/main/java/com/hazelcast/sql/impl/state/QueryClientStateRegistry.java:210
↓ 2 callersMethodcloseAllChannels
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TpcChannelConnector.java:207
↓ 2 callersMethodcloseAllQuietly
Closes the collection of AutoClosables quietly. <p/> If the collection is null, the call is ignored. <p/> If an element in the collection is null, tha
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/CloseUtil.java:41
↓ 2 callersMethodcloseChannel
(Channel channel)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TpcChannelConnector.java:203
↓ 2 callersMethodcloseDeflater
Only close deflater, we don't want to close underlying OutputStream
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/defaultserializers/JavaDefaultSerializers.java:546
↓ 2 callersMethodcloseFile
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteFileP.java:363
↓ 2 callersMethodcloseInflater
Only close inflater, we don't want to close underlying InputStream
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/defaultserializers/JavaDefaultSerializers.java:530
↓ 2 callersMethodcloseIsCooperative
Returns {@code true} if the {@link #close(Throwable)} method of this instance is cooperative. If it's not, the call to the {@code close()} method is o
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:172
↓ 2 callersMethodcloseLog
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:576
↓ 2 callersMethodcloseProcessor
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ProcessorTasklet.java:310
↓ 2 callersMethodcloseScheduler
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:556
↓ 2 callersMethodcloseSelector
()
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioThread.java:389
↓ 2 callersMethodcloseSockets
(HazelcastInstanceImpl factory)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryHandlerHelper.java:44
↓ 2 callersMethodcloseTraverser
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransformBatchedAutoCloseableP.java:74
↓ 2 callersMethodclusterConnectionSucceeded
Triggered after connection to at least one cluster member is established.
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListener.java:122
↓ 2 callersMethodclusterEcs
()
hazelcast/src/main/java/com/hazelcast/aws/AwsMetadataApi.java:97
↓ 2 callersMethodcoerceItem
( HazelcastSqlValidator validator, SqlValidatorScope scope, SqlNode item,
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/misc/HazelcastCaseOperator.java:145
↓ 2 callersMethodcoerceNode
( SqlValidatorScope scope, SqlNode node, RelDataType targetType,
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeCoercion.java:69
↓ 2 callersMethodcollect
(MetricDescriptor descriptor, Object source, ProbeFunction function)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCollectionCycle.java:146
↓ 2 callersMethodcollectAllDynamicConfigs
()
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ClusterWideConfigurationService.java:193
↓ 2 callersMethodcollectAllServiceNamespaces
Collect the namespaces of all WAN event containers that should be replicated by the replication event. Invoked when migrating WAN replication data bet
hazelcast/src/main/java/com/hazelcast/wan/WanMigrationAwarePublisher.java:99
↓ 2 callersMethodcollectAndVerify
(IntStream stream)
hazelcast/src/test/java/com/hazelcast/jet/aggregate/AggregateOperationsTest.java:670
↓ 2 callersMethodcollectCustomSteps
(MapOperation operation, Consumer<Step> consumer)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/StepSupplier.java:84
↓ 2 callersMethodcollectCustomSteps
Appends provided step to the head of step-chain. @param steps consumer which adds step to the head of step-chain.
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/CustomStepAwareStorage.java:34
↓ 2 callersMethodcollectDouble
(Object source, MetricDescriptor descriptor, DoubleProbeFunction function)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCollectionCycle.java:164
← previousnext →16,901–17,000 of 147,315, ranked by callers