MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListIntegerUUIDCodec.java:55
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListUUIDUUIDCodec.java:52
↓ 2 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListIntegerCodec.java:45
↓ 2 callersMethoddecodeHashPPrimeIndex
(int hash)
hazelcast/src/main/java/com/hazelcast/cardinality/impl/hyperloglog/impl/SparseHyperLogLogEncoder.java:155
↓ 2 callersMethoddecorateAndInvokeRunOnDifferentThread
(Runnable task,
hazelcast/src/test/java/com/hazelcast/spi/impl/executionservice/impl/DelegateAndSkipOnConcurrentExecutionDecoratorTest.java:100
↓ 2 callersMethoddecreaseCacheEntryListenerCount
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheContext.java:65
↓ 2 callersMethoddecreaseInvalidationListenerCount
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:131
↓ 2 callersMethoddecrement0
(UUID txnId, boolean decrementNodeWideCounter)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/TxnReservedCapacityCounterImpl.java:116
↓ 2 callersMethoddecrementOnlyReserved
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 callersMethoddeduceElementType
(MultiResult multiResult, Reader reader)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/GetterFactory.java:116
↓ 2 callersMethoddefaultEnumerator
()
hazelcast/src/main/java/com/hazelcast/internal/util/NetworkInterfacesEnumerator.java:28
↓ 2 callersMethoddefaultIamRoleEc2
()
hazelcast/src/test/java/com/hazelcast/aws/AwsMetadataApiTest.java:182
↓ 2 callersMethoddefaultPartitioner
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 callersMethoddefineClassFromClient
(final String name, final byte[] classDef, Map<String, byte[]> bundledClassDefinitions)
hazelcast/src/main/java/com/hazelcast/internal/usercodedeployment/impl/ClassLocator.java:111
↓ 2 callersMethoddefinePackage
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 callersMethoddelayRepartitionForHotRestartRecovery
(MemberMap memberMap, MemberInfo member)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:840
↓ 2 callersMethoddelegate
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 callersMethoddelegateForCollection
(MongoCollection<Document> collection, List<Bson> ag
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoP.java:352
↓ 2 callersMethoddelegateForDb
(MongoDatabase database, List<Bson> aggregateList)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoP.java:357
↓ 2 callersMethoddelete
()
extensions/mapstore/src/main/java/com/hazelcast/mapstore/Queries.java:184
↓ 2 callersMethoddelete
(K key)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:98
↓ 2 callersMethoddelete
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 callersMethoddeleteAll
(int n)
extensions/mapstore/src/main/java/com/hazelcast/mapstore/Queries.java:188
↓ 2 callersMethoddeleteAll
(String mapName)
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandService.java:90
↓ 2 callersMethoddeleteCache
(String cacheNameWithPrefix, UUID callerUuid, boolean destroy)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:345
↓ 2 callersMethoddeleteItemsFromIndexPipeline
( String index, SupplierEx<RestClientBuilder> elasticSupplier, TestItem...
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/pipeline/CommonElasticSinksPipeline.java:92
↓ 2 callersMethoddeleteJob
Performs cleanup after job completion.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:452
↓ 2 callersMethoddeleteRecordStore
(String name, boolean destroy)
hazelcast/src/main/java/com/hazelcast/cache/impl/CachePartitionSegment.java:130
↓ 2 callersMethoddeleteStream
()
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisTestHelper.java:128
↓ 2 callersMethoddemoteAndGetLocalMember
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:1089
↓ 2 callersMethoddenseCapacityDeltaShort
Computes capacity delta for dense directly indexable short arrays.
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapUtils.java:171
↓ 2 callersMethodderegister
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 callersMethodderegister
(AtomicReference<HazelcastInstance[]> ref, HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:106
↓ 2 callersMethodderegisterAllCacheEntryListener
(Collection<UUID> listenerRegistrations)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:566
↓ 2 callersMethodderegisterAllCacheEntryListener
(Collection<UUID> listenerRegistrations)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:818
↓ 2 callersMethodderegisterCacheEntryListener
(CacheEntryListenerConfiguration<K, V> cacheEntryListenerConfiguration)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxy.java:301
↓ 2 callersMethodderegisterClient
(HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:102
↓ 2 callersMethodderegisterLifecycleListener
()
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:300
↓ 2 callersMethodderegisterListenerInternal
(@Nullable UUID userRegistrationId)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerServiceImpl.java:359
↓ 2 callersMethodderiveType
( SqlValidator validator, SqlValidatorScope scope, SqlCall call)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/predicate/HazelcastInOperator.java:66
↓ 2 callersMethoddescribe
()
hazelcast/src/test/java/com/hazelcast/internal/adapter/MethodAvailableMatcher.java:72
↓ 2 callersMethoddescribeInstances
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 callersMethoddescribeNetworkInterfaces
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 callersMethoddeserialize
(SerializationService serializationService)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/LazyTarget.java:54
↓ 2 callersMethoddeserializeAndSet
(Object o)
hazelcast/src/main/java/com/hazelcast/spi/impl/UnmodifiableLazyList.java:179
↓ 2 callersMethoddestroy
Closes underlying client.
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java:247
↓ 2 callersMethoddestroy
()
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointImpl.java:259
↓ 2 callersMethoddestroy
()
hazelcast/src/main/java/com/hazelcast/collection/impl/collection/CollectionContainer.java:340
↓ 2 callersMethoddestroy
()
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:1211
↓ 2 callersMethoddestroy
()
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:138
↓ 2 callersMethoddestroy
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 callersMethoddestroy
Destroy the underlying distributed object.
hazelcast/src/main/java/com/hazelcast/jet/JobStateSnapshot.java:105
↓ 2 callersMethoddestroy
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapStoreWrapper.java:85
↓ 2 callersMethoddestroy
Prepare this tracker for shutdown.
hazelcast/src/main/java/com/hazelcast/instance/impl/ClusterTopologyIntentTracker.java:116
↓ 2 callersMethoddestroyAllDistributedObjects
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1665
↓ 2 callersMethoddestroyAllNearCaches
Destroys all defined {@link NearCache} instances.
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCacheManager.java:93
↓ 2 callersMethoddestroyAllQueryCaches
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheEndToEndProvider.java:116
↓ 2 callersMethoddestroyContainer
(String name)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainerHolder.java:27
↓ 2 callersMethoddestroyDistributedObject
(String serviceName, String objectId, UUID source)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/ProxyService.java:40
↓ 2 callersMethoddestroyLocalDistributedObject
(String serviceName, String name, UUID source, boolean fireEvent)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/ProxyServiceImpl.java:185
↓ 2 callersMethoddestroyLocalMapStatsImpl
(String name)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:114
↓ 2 callersMethoddestroyNearCache
()
hazelcast/src/main/java/com/hazelcast/client/cache/impl/nearcache/NearCachedClientCacheProxy.java:688
↓ 2 callersMethoddestroyNearCache
()
hazelcast/src/main/java/com/hazelcast/client/map/impl/nearcache/NearCachedClientMapProxy.java:620
↓ 2 callersMethoddestroyNearCache
()
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReplicatedMapProxy.java:161
↓ 2 callersMethoddestroyObjects
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/HazelcastRemoteConnectorTest.java:134
↓ 2 callersMethoddestroyProxy
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 callersMethoddetectAndHandleBackupTimeout
@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 callersMethoddigit
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/util/ThreadAffinity.java:267
↓ 2 callersMethoddisable
()
hazelcast/src/test/java/com/hazelcast/test/metrics/MetricsRule.java:44
↓ 2 callersMethoddisableAllGroups
Disables all REST endpoint groups.
hazelcast/src/main/java/com/hazelcast/config/RestApiConfig.java:77
↓ 2 callersMethoddiscardReserved
(int partitionId, int thresholdReplicaIndex)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/DistributedScheduledExecutorService.java:274
↓ 2 callersMethoddiscoverLocalMetadata
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 callersMethoddiscoveryStrategyConfigYamlGenerator
(Map<String, Object> parent, DiscoveryConfig discoveryConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGenerator.java:863
↓ 2 callersMethoddiscoveryStrategyLevel
Level of the discovery strategy.
hazelcast/src/main/java/com/hazelcast/spi/discovery/DiscoveryStrategyFactory.java:92
↓ 2 callersMethoddismissTasklet
(TaskletTracker t)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/TaskletExecutionService.java:430
↓ 2 callersMethoddispatch0
(IMapEvent event, EntryListener listener)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapEventsDispatcher.java:104
↓ 2 callersMethoddispatchFullQueryOnQueryThread
(TargetMode target)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryEngine_DispatchTest.java:92
↓ 2 callersMethoddispatchLocalEventData
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 callersMethoddispose
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 callersMethoddispose
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 callersMethoddispose
(String taskName)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:190
↓ 2 callersMethoddisposeResult
(int sequence)
hazelcast/src/main/java/com/hazelcast/durableexecutor/impl/DurableExecutorContainer.java:109
↓ 2 callersMethoddistanceFromBase
(PartitionTableView partitionTableView)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:2105
↓ 2 callersMethoddistinctP
(FunctionEx<? super T, ? extends K> keyFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/DistinctTransform.java:61
↓ 2 callersMethoddistributedObjectCreated
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 callersMethoddistributedObjectDestroyed
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 callersMethoddmlSupportsPredicates
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 callersMethoddmlVertex
( DagBuildContext context, boolean hasInput, JdbcTable table,
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlConnector.java:490
↓ 2 callersMethoddoActualRead
(ByteBuffer src)
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpPostCommand.java:81
↓ 2 callersMethoddoConnectToCandidateCluster
(CandidateClusterContext context, boolean switchingToNextCluster)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:544
↓ 2 callersMethoddoConnectToCluster
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:465
↓ 2 callersMethoddoCreateNearCacheAndWaitForExpirationCalled
(boolean useTTL)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestSupport.java:206
↓ 2 callersMethoddoExecute
(String executorName, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperation.java:503
↓ 2 callersMethoddoExportSnapshot
(String name, boolean cancelJob)
hazelcast/src/main/java/com/hazelcast/jet/impl/AbstractJobProxy.java:397
↓ 2 callersMethoddoFullScan
(Predicate predicate, BiConsumer biConsumer)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/AbstractInternalQueryCache.java:230
↓ 2 callersMethoddoFunctionalSQLQueryTest
(IMap<String, Employee> map)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryBasicTest.java:603
↓ 2 callersMethoddoGet
(HttpServletRequest req, HttpServletResponse resp)
hazelcast/src/test/java/com/hazelcast/internal/util/ServiceLoaderTest.java:558
↓ 2 callersMethoddoGetAndReplaceOnServer
(Data keyData, Data newValueData, Data expiryPoli
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:551
↓ 2 callersMethoddoJoin
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/AbstractJoiner.java:134
↓ 2 callersMethoddoPing
(Address address, Level level)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterHeartbeatManager.java:708
← previousnext →17,501–17,600 of 147,315, ranked by callers