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
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListIntegerUUIDCodec.java:55
↓ 2 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListUUIDUUIDCodec.java:52
↓ 2 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListIntegerCodec.java:45
↓ 2 callers
Method
decodeHashPPrimeIndex
(int hash)
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/SparseHyperLogLogEncoder.java:155
↓ 2 callers
Method
decorateAndInvokeRunOnDifferentThread
(Runnable task,
hazelcast/src/test/java/com/hazelcast/spi/impl/executionservice/impl/DelegateAndSkipOnConcurrentExecutionDecoratorTest.java:100
↓ 2 callers
Method
decreaseCacheEntryListenerCount
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheContext.java:65
↓ 2 callers
Method
decreaseInvalidationListenerCount
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:131
↓ 2 callers
Method
decrement0
(UUID txnId, boolean decrementNodeWideCounter)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/TxnReservedCapacityCounterImpl.java:116
↓ 2 callers
Method
decrementOnlyReserved
Decrements capacity count for a transaction. @param txnId id of transaction
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/TxnReservedCapacityCounter.java:77
↓ 2 callers
Method
deduceElementType
(MultiResult multiResult, Reader reader)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/GetterFactory.java:116
↓ 2 callers
Method
defaultEnumerator
()
hazelcast/src/main/java/com/hazelcast/internal/util/NetworkInterfacesEnumerator.java:28
↓ 2 callers
Method
defaultIamRoleEc2
()
hazelcast/src/test/java/com/hazelcast/aws/AwsMetadataApiTest.java:182
↓ 2 callers
Method
defaultPartitioner
Returns a partitioner which applies the default Hazelcast partitioning. It will serialize the item using Hazelcast Serialization, then apply Hazelcast
hazelcast/src/main/java/com/hazelcast/jet/core/Partitioner.java:110
↓ 2 callers
Method
defineClassFromClient
(final String name, final byte[] classDef, Map<String, byte[]> bundledClassDefinitions)
hazelcast/src/main/java/com/hazelcast/internal/usercodedeployment/impl/ClassLocator.java:111
↓ 2 callers
Method
definePackage
Defines the package if it is not already defined for the given class name. @param className the class name
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/MapResourceClassLoader.java:301
↓ 2 callers
Method
delayRepartitionForHotRestartRecovery
(MemberMap memberMap, MemberInfo member)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:840
↓ 2 callers
Method
delegate
Returns a new tenant contextual that shares the same {@link TenantControl} and other fields set when constructing this object but with the actual unde
hazelcast/src/main/java/com/hazelcast/spi/impl/tenantcontrol/TenantContextual.java:103
↓ 2 callers
Method
delegateForCollection
(MongoCollection<Document> collection, List<Bson> ag
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoP.java:352
↓ 2 callers
Method
delegateForDb
(MongoDatabase database, List<Bson> aggregateList)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoP.java:357
↓ 2 callers
Method
delete
()
extensions/mapstore/src/main/java/com/hazelcast/mapstore/Queries.java:184
↓ 2 callers
Method
delete
(K key)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:98
↓ 2 callers
Method
delete
Transactional implementation of {@link IMap#delete(Object)}. <p> The object to be deleted will be removed from only the current transaction context un
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:218
↓ 2 callers
Method
deleteAll
(int n)
extensions/mapstore/src/main/java/com/hazelcast/mapstore/Queries.java:188
↓ 2 callers
Method
deleteAll
(String mapName)
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandService.java:90
↓ 2 callers
Method
deleteCache
(String cacheNameWithPrefix, UUID callerUuid, boolean destroy)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:345
↓ 2 callers
Method
deleteItemsFromIndexPipeline
( String index, SupplierEx<RestClientBuilder> elasticSupplier, TestItem...
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/pipeline/CommonElasticSinksPipeline.java:92
↓ 2 callers
Method
deleteJob
Performs cleanup after job completion.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:452
↓ 2 callers
Method
deleteRecordStore
(String name, boolean destroy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CachePartitionSegment.java:130
↓ 2 callers
Method
deleteStream
()
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisTestHelper.java:128
↓ 2 callers
Method
demoteAndGetLocalMember
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:1089
↓ 2 callers
Method
denseCapacityDeltaShort
Computes capacity delta for dense directly indexable short arrays.
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapUtils.java:171
↓ 2 callers
Method
deregister
De-registers {@link MapInterceptor} for the supplied `id`, if there is any. This method is called by {@link com.hazelcast.spi.impl.operationexecutor.
hazelcast/src/main/java/com/hazelcast/map/impl/InterceptorRegistry.java:108
↓ 2 callers
Method
deregister
(AtomicReference<HazelcastInstance[]> ref, HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:106
↓ 2 callers
Method
deregisterAllCacheEntryListener
(Collection<UUID> listenerRegistrations)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:566
↓ 2 callers
Method
deregisterAllCacheEntryListener
(Collection<UUID> listenerRegistrations)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:818
↓ 2 callers
Method
deregisterCacheEntryListener
(CacheEntryListenerConfiguration<K, V> cacheEntryListenerConfiguration)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxy.java:301
↓ 2 callers
Method
deregisterClient
(HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:102
↓ 2 callers
Method
deregisterLifecycleListener
()
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:300
↓ 2 callers
Method
deregisterListenerInternal
(@Nullable UUID userRegistrationId)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerServiceImpl.java:359
↓ 2 callers
Method
deriveType
( SqlValidator validator, SqlValidatorScope scope, SqlCall call)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/predicate/HazelcastInOperator.java:66
↓ 2 callers
Method
describe
()
hazelcast/src/test/java/com/hazelcast/internal/adapter/MethodAvailableMatcher.java:72
↓ 2 callers
Method
describeInstances
Calls AWS EC2 Describe Instances API, parses the response, and returns mapping from private to public IPs. <p> Note that if EC2 Instance does not have
hazelcast/src/main/java/com/hazelcast/aws/AwsEc2Api.java:64
↓ 2 callers
Method
describeNetworkInterfaces
Calls AWS EC2 Describe Network Interfaces API, parses the response, and returns mapping from private to public IPs. <p> Note that if the given private
hazelcast/src/main/java/com/hazelcast/aws/AwsEc2Api.java:179
↓ 2 callers
Method
deserialize
(SerializationService serializationService)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/LazyTarget.java:54
↓ 2 callers
Method
deserializeAndSet
(Object o)
hazelcast/src/main/java/com/hazelcast/spi/impl/UnmodifiableLazyList.java:179
↓ 2 callers
Method
destroy
Closes underlying client.
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java:247
↓ 2 callers
Method
destroy
()
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointImpl.java:259
↓ 2 callers
Method
destroy
()
hazelcast/src/main/java/com/hazelcast/collection/impl/collection/CollectionContainer.java:340
↓ 2 callers
Method
destroy
()
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:1211
↓ 2 callers
Method
destroy
()
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:138
↓ 2 callers
Method
destroy
Releases all resources hold by this index, e.g. the allocated native memory for the HD index.
hazelcast/src/main/java/com/hazelcast/query/impl/Index.java:288
↓ 2 callers
Method
destroy
Destroy the underlying distributed object.
hazelcast/src/main/java/com/hazelcast/jet/JobStateSnapshot.java:105
↓ 2 callers
Method
destroy
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapStoreWrapper.java:85
↓ 2 callers
Method
destroy
Prepare this tracker for shutdown.
hazelcast/src/main/java/com/hazelcast/instance/impl/ClusterTopologyIntentTracker.java:116
↓ 2 callers
Method
destroyAllDistributedObjects
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1665
↓ 2 callers
Method
destroyAllNearCaches
Destroys all defined {@link NearCache} instances.
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCacheManager.java:93
↓ 2 callers
Method
destroyAllQueryCaches
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheEndToEndProvider.java:116
↓ 2 callers
Method
destroyContainer
(String name)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainerHolder.java:27
↓ 2 callers
Method
destroyDistributedObject
(String serviceName, String objectId, UUID source)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/ProxyService.java:40
↓ 2 callers
Method
destroyLocalDistributedObject
(String serviceName, String name, UUID source, boolean fireEvent)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/ProxyServiceImpl.java:185
↓ 2 callers
Method
destroyLocalMapStatsImpl
(String name)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:114
↓ 2 callers
Method
destroyNearCache
()
hazelcast/src/main/java/com/hazelcast/client/cache/impl/nearcache/NearCachedClientCacheProxy.java:688
↓ 2 callers
Method
destroyNearCache
()
hazelcast/src/main/java/com/hazelcast/client/map/impl/nearcache/NearCachedClientMapProxy.java:620
↓ 2 callers
Method
destroyNearCache
()
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReplicatedMapProxy.java:161
↓ 2 callers
Method
destroyObjects
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/HazelcastRemoteConnectorTest.java:134
↓ 2 callers
Method
destroyProxy
Destroys a proxy. @param name The name of the proxy to destroy. @param source The UUID of the client or member which initialized destro
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/ProxyRegistry.java:303
↓ 2 callers
Method
detectAndHandleBackupTimeout
@param timeoutMillis timeout value to wait for backups after the response received @return true if invocation is completed
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/BaseInvocation.java:120
↓ 2 callers
Method
digit
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/util/ThreadAffinity.java:267
↓ 2 callers
Method
disable
()
hazelcast/src/test/java/com/hazelcast/test/metrics/MetricsRule.java:44
↓ 2 callers
Method
disableAllGroups
Disables all REST endpoint groups.
hazelcast/src/main/java/com/hazelcast/config/RestApiConfig.java:77
↓ 2 callers
Method
discardReserved
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/DistributedScheduledExecutorService.java:274
↓ 2 callers
Method
discoverLocalMetadata
Returns a map with discovered metadata provided by the runtime environment. Those information may include, but are not limited, to location informatio
hazelcast/src/main/java/com/hazelcast/spi/discovery/integration/DiscoveryService.java:89
↓ 2 callers
Method
discoveryStrategyConfigYamlGenerator
(Map<String, Object> parent, DiscoveryConfig discoveryConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGenerator.java:863
↓ 2 callers
Method
discoveryStrategyLevel
Level of the discovery strategy.
hazelcast/src/main/java/com/hazelcast/spi/discovery/DiscoveryStrategyFactory.java:92
↓ 2 callers
Method
dismissTasklet
(TaskletTracker t)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/TaskletExecutionService.java:430
↓ 2 callers
Method
dispatch0
(IMapEvent event, EntryListener listener)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapEventsDispatcher.java:104
↓ 2 callers
Method
dispatchFullQueryOnQueryThread
(TargetMode target)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryEngine_DispatchTest.java:92
↓ 2 callers
Method
dispatchLocalEventData
Dispatches an event-data to {@link com.hazelcast.map.QueryCache QueryCache} listeners on this local node. @param eventData {@link EventData} to be di
hazelcast/src/main/java/com/hazelcast/map/impl/event/MapEventPublishingService.java:165
↓ 2 callers
Method
dispose
Implementers can override to release associated resources upon a successful execution or failure.
hazelcast/src/main/java/com/hazelcast/cache/impl/operation/CacheOperation.java:139
↓ 2 callers
Method
dispose
Used to destroy the instance of the {@link IScheduledFuture} in the scheduled executor. Once the instance is destroyed, any subsequent action on the {
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledFuture.java:56
↓ 2 callers
Method
dispose
(String taskName)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:190
↓ 2 callers
Method
disposeResult
(int sequence)
hazelcast/src/main/java/com/hazelcast/durableexecutor/impl/DurableExecutorContainer.java:109
↓ 2 callers
Method
distanceFromBase
(PartitionTableView partitionTableView)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:2105
↓ 2 callers
Method
distinctP
(FunctionEx<? super T, ? extends K> keyFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/DistinctTransform.java:61
↓ 2 callers
Method
distributedObjectCreated
Invoked when a DistributedObject is created. @param event the event for the created DistributedObject
hazelcast/src/main/java/com/hazelcast/core/DistributedObjectListener.java:35
↓ 2 callers
Method
distributedObjectDestroyed
Invoked when a DistributedObject is destroyed. @param event the event for the destroyed DistributedObject
hazelcast/src/main/java/com/hazelcast/core/DistributedObjectListener.java:42
↓ 2 callers
Method
dmlSupportsPredicates
Returns whether this processor's {@link #deleteProcessor} and {@link #updateProcessor} methods can use a predicate.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/SqlConnector.java:494
↓ 2 callers
Method
dmlVertex
( DagBuildContext context, boolean hasInput, JdbcTable table,
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlConnector.java:490
↓ 2 callers
Method
doActualRead
(ByteBuffer src)
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpPostCommand.java:81
↓ 2 callers
Method
doConnectToCandidateCluster
(CandidateClusterContext context, boolean switchingToNextCluster)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:544
↓ 2 callers
Method
doConnectToCluster
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:465
↓ 2 callers
Method
doCreateNearCacheAndWaitForExpirationCalled
(boolean useTTL)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestSupport.java:206
↓ 2 callers
Method
doExecute
(String executorName, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperation.java:503
↓ 2 callers
Method
doExportSnapshot
(String name, boolean cancelJob)
hazelcast/src/main/java/com/hazelcast/jet/impl/AbstractJobProxy.java:397
↓ 2 callers
Method
doFullScan
(Predicate predicate, BiConsumer biConsumer)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/AbstractInternalQueryCache.java:230
↓ 2 callers
Method
doFunctionalSQLQueryTest
(IMap<String, Employee> map)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryBasicTest.java:603
↓ 2 callers
Method
doGet
(HttpServletRequest req, HttpServletResponse resp)
hazelcast/src/test/java/com/hazelcast/internal/util/ServiceLoaderTest.java:558
↓ 2 callers
Method
doGetAndReplaceOnServer
(Data keyData, Data newValueData, Data expiryPoli
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:551
↓ 2 callers
Method
doJoin
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/AbstractJoiner.java:134
↓ 2 callers
Method
doPing
(Address address, Level level)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterHeartbeatManager.java:708
← previous
next →
17,501–17,600 of 147,315, ranked by callers