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
addCacheConfig
(String cacheName, CacheConfig cacheConfig)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxyFactory.java:62
↓ 2 callers
Method
addCacheConfigIfAbsent
(CacheConfig<K, V> cacheConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:419
↓ 2 callers
Method
addCachePartitionLostListenerConfig
(CachePartitionLostListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/CacheSimpleConfigReadOnly.java:162
↓ 2 callers
Method
addChild
Adds a child node to this Json node. It is added as the last item in order.
hazelcast/src/main/java/com/hazelcast/json/internal/JsonSchemaStructNode.java:48
↓ 2 callers
Method
addConditionToQuery
(Query query, String condition, boolean conjunction)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/index/SqlIndexAbstractTest.java:984
↓ 2 callers
Method
addCountIndex
(DelayedEntry entry)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/CyclicWriteBehindQueue.java:176
↓ 2 callers
Method
addCpuRangeToGroup
(CpuGroup group)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/util/ThreadAffinity.java:245
↓ 2 callers
Method
addCustomClasspaths
Adds custom classpath elements to a stage with the given name. <pre>{@code BatchSource<String> source = ... JobConfig config = new JobConfig(); confi
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:683
↓ 2 callers
Method
addDefaultBlocklist
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/ReflectionClassNameFilter.java:52
↓ 2 callers
Method
addDiscoveryStrategyConfig
(DiscoveryStrategyConfig discoveryStrategyConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/DiscoveryConfigReadOnly.java:52
↓ 2 callers
Method
addEndpoint
(String endpoint)
hazelcast/src/main/java/com/hazelcast/config/PermissionConfig.java:259
↓ 2 callers
Method
addEntry
(Long id, ScheduledEntry<K, V> entry)
hazelcast/src/main/java/com/hazelcast/internal/util/scheduler/SecondsBasedEntryTaskScheduler.java:317
↓ 2 callers
Method
addEntryListenerConfig
(EntryListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/config/ReplicatedMapConfig.java:154
↓ 2 callers
Method
addEntryListenerInternal
(MapListener listener, K key, boolean includeValue)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/DefaultQueryCache.java:384
↓ 2 callers
Method
addEventData
Helper method for adding multiple CacheEventData into this Set @param cacheEventData event data representing a single event's data. @see CacheEventDat
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventSet.java:93
↓ 2 callers
Method
addEventToQueryCache
(Data dataKey, Record record)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:947
↓ 2 callers
Method
addExecutionContextJobId
(long jobId, long executionId, Address coordinator)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionService.java:353
↓ 2 callers
Method
addExpired
(@Nonnull String shardId)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:34
↓ 2 callers
Method
addFilter
(@Nonnull String filterClassName)
hazelcast/src/main/java/com/hazelcast/internal/config/WanReplicationRefReadOnly.java:48
↓ 2 callers
Method
addFilter
Adds the class name implementing the CacheWanEventFilter or MapWanEventFilter for filtering outbound WAN replication events. <p> NOTE: EE only @param
hazelcast/src/main/java/com/hazelcast/config/WanReplicationRef.java:119
↓ 2 callers
Method
addForcibly
(DelayedEntry<Data, Object> delayedEntry)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindStore.java:183
↓ 2 callers
Method
addGroupAvailabilityListener
Registers a new CPGroupAvailabilityListener to listen CP group availability changes. @param listener group availability listener @return id of the li
hazelcast/src/main/java/com/hazelcast/cp/CPSubsystem.java:603
↓ 2 callers
Method
addIndex
(IMap<?, ?> map)
hazelcast/src/test/java/com/hazelcast/map/IndexStatsChangingNumberOfMembersTest.java:430
↓ 2 callers
Method
addIndexCofigs
(Collection<IndexConfig> indexConfigs)
hazelcast/src/main/java/com/hazelcast/query/impl/MapIndexInfo.java:43
↓ 2 callers
Method
addIndexConfigToNewMapContainer
(String mapName, int partitionId, IndexRegistry indexRegistry
hazelcast/src/main/java/com/hazelcast/map/impl/MapSplitBrainHandlerService.java:131
↓ 2 callers
Method
addIndexStats
(String mapName, LocalMapStatsImpl localMapStats)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:347
↓ 2 callers
Method
addInfiniteRanges
Adds infinite ranges to filter components, to match the number of index components. <p> For example, for the index on {@code (a, b)} and the expressio
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:1347
↓ 2 callers
Method
addInner
Adds another contributing pipeline stage to the hash-join operation. <p> If no matching items for returned {@linkplain Tag tag} is found, no records f
hazelcast/src/main/java/com/hazelcast/jet/pipeline/GeneralHashJoinBuilder.java:103
↓ 2 callers
Method
addInternal
(T item)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:553
↓ 2 callers
Method
addInternal
(T item)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/SourceBufferImpl.java:42
↓ 2 callers
Method
addJar
(@Nonnull URL url, @Nullable String id)
hazelcast/src/main/java/com/hazelcast/config/UserCodeNamespaceConfig.java:91
↓ 2 callers
Method
addJarsInZip
(@Nonnull URL url, @Nullable String id)
hazelcast/src/main/java/com/hazelcast/config/UserCodeNamespaceConfig.java:95
↓ 2 callers
Method
addJsonIfSerializable
(JsonObject root, String key, Object value)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/MemberStateImpl.java:369
↓ 2 callers
Method
addListenerDestroyAction
Adds a remove callable to be called when endpoint is destroyed to clean related listener Following line will be called when endpoint destroyed : event
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpoint.java:57
↓ 2 callers
Method
addListenerInternal
(Object listener, EventFilter filter, String mapName, boolean local)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextImpl.java:807
↓ 2 callers
Method
addLoadedListener
(IMap map, final CountDownLatch counter)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/LoadAllTest.java:237
↓ 2 callers
Method
addLocalMigrationListener
(MigrationListener migrationListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:138
↓ 2 callers
Method
addLockConfig
(FencedLockConfig lockConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicCPSubsystemConfig.java:97
↓ 2 callers
Method
addLockConfig
Adds the {@link FencedLock} configuration. Name of the {@link FencedLock} could optionally contain a {@link CPGroup} name, like "myLock@group1". @par
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:753
↓ 2 callers
Method
addMemberPrefixFn
(@Nonnull Member member)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobMetricsUtil.java:52
↓ 2 callers
Method
addMessageListenerConfig
(ListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/TopicConfigReadOnly.java:61
↓ 2 callers
Method
addMessageListenerConfig
Adds a message listener (listens for when messages are added or removed) to this reliable topic. @param listenerConfig the ListenerConfig to add @ret
hazelcast/src/main/java/com/hazelcast/config/ReliableTopicConfig.java:297
↓ 2 callers
Method
addMessageListenerInternal
(@Nonnull MessageListener listener)
hazelcast/src/main/java/com/hazelcast/topic/impl/TopicProxySupport.java:102
↓ 2 callers
Method
addMigrationListenerAsync
(MigrationListener migrationListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:136
↓ 2 callers
Method
addMulti
(String name, Collection<String> values)
hazelcast/src/main/java/com/hazelcast/aws/Filter.java:38
↓ 2 callers
Method
addMulticastListener
(MulticastListener multicastListener)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MulticastService.java:178
↓ 2 callers
Method
addNearCacheStats
(String mapName, LocalMapStatsImpl localMapStats, LocalMapOnDemandCalculate
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:333
↓ 2 callers
Method
addNewAddressToAddressMap
(int id, String host, int initialPort)
hazelcast/src/test/java/com/hazelcast/test/TestHazelcastInstanceFactory.java:517
↓ 2 callers
Method
addNewWorkerIfRequired
()
hazelcast/src/main/java/com/hazelcast/internal/util/executor/CachedExecutorServiceDelegate.java:131
↓ 2 callers
Method
addNode
(PartitionReplica replica)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:404
↓ 2 callers
Method
addOperation
(CollectionTxnOperation operation)
hazelcast/src/main/java/com/hazelcast/collection/impl/txncollection/CollectionTransactionLogRecord.java:80
↓ 2 callers
Method
addOutboundPortDefinition
Add outbound port definition to the outbound port definition list @param portDef outbound port definition @return ClientNetworkConfig
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:510
↓ 2 callers
Method
addOwnInterfaces
(Class<?> clazz, Collection<Class<?>> allInterfaces)
hazelcast/src/main/java/com/hazelcast/internal/nio/ClassLoaderUtil.java:387
↓ 2 callers
Method
addPart
(List<String> list, StringBuilder sb, boolean trim)
hazelcast-build-utils/src/main/java/com/hazelcast/buildutils/ElementParser.java:106
↓ 2 callers
Method
addPartitionLostListenerInternal
(MapPartitionLostListener listener)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:1282
↓ 2 callers
Method
addPermissionForTable
(RelOptTable t, String action)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/CalciteSqlOptimizerImpl.java:736
↓ 2 callers
Method
addPersistence
(long duration, int writtenBytes, int keyCount)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImpl.java:250
↓ 2 callers
Method
addPortableFactories
(Config config)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryBasicTest.java:995
↓ 2 callers
Method
addPortableFactory
(int id, PortableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DefaultSerializationServiceBuilder.java:151
↓ 2 callers
Method
addRealmReference
(XmlGenerator gen, String refName, String realmName)
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:288
↓ 2 callers
Method
addRegistration
Adds a registration for the {@code topic} and notifies the listener and service of the listener registration. Returns if the registration was added. T
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/EventServiceSegment.java:163
↓ 2 callers
Method
addReplicaSyncPermits
(InternalPartitionServiceImpl partitionService, int k)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionReplicaStateCheckerTest.java:240
↓ 2 callers
Method
addResources
(List<DataConnectionResource> resources, MongoDatabase database)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java:237
↓ 2 callers
Method
addResultsOfPredicate
(List<Future<Result>> futures, Result result, PartitionIdSet unfinished
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryEngineImpl.java:208
↓ 2 callers
Method
addRow
Adds the given row into this result. @param row the row to add.
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResult.java:176
↓ 2 callers
Method
addSecurityFeatureInfo
(StringBuilder sb, String feature)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeSecurityBanner.java:163
↓ 2 callers
Method
addSecurityInterceptorConfig
(SecurityInterceptorConfig interceptorConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicSecurityConfig.java:51
↓ 2 callers
Method
addSemaphoreConfig
(SemaphoreConfig semaphoreConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicCPSubsystemConfig.java:87
↓ 2 callers
Method
addSemaphoreConfig
Adds the CP {@link ISemaphore} configuration. Name of the CP {@link ISemaphore} could optionally contain a {@link CPGroup} name, like "mySemaphore@gro
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:700
↓ 2 callers
Method
addStatsOfBackupReplica
(RecordStore recordStore, LocalMapOnDemandCalculatedStats onDemandStats)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:256
↓ 2 callers
Method
addStatsOfPrimaryReplica
(RecordStore recordStore, LocalMapOnDemandCalculatedStats onD
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:233
↓ 2 callers
Method
addStructureStats
Adds stats related to the data structure itself that should be reported even if the map or some of its {@link RecordStore} is empty @param mapName
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:229
↓ 2 callers
Method
addTask
Adds a task to this NioThread without notifying the thread. @param task the task to add @throws NullPointerException if task is null
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioThread.java:211
↓ 2 callers
Method
addTemporaryMemberAddress
(Address memberAddress)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/TcpIpJoiner.java:477
↓ 2 callers
Method
addToQueue
(Queue<? super E> queue, int capacity, E o)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:94
↓ 2 callers
Method
addWanReplicationConfig
Adds the WAN replication config under the name defined by {@link WanReplicationConfig#getName()}. @param wanReplicationConfig the WAN replication con
hazelcast/src/main/java/com/hazelcast/config/Config.java:2288
↓ 2 callers
Method
addWhitespace
(Node node)
hazelcast/src/test/java/com/hazelcast/config/XmlOnlyConfigBuilderTest.java:305
↓ 2 callers
Method
addWindowBounds
Returns a traverser of rows with two added fields: the window_start and window_end. For tumbling windows, the returned traverser always contains a sin
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/WindowUtils.java:92
↓ 2 callers
Method
addWithBackoff
(Collection<ReliableTopicMessage> messages)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReliableTopicProxy.java:148
↓ 2 callers
Method
addWithBackoff
(Collection<ReliableTopicMessage> messages)
hazelcast/src/main/java/com/hazelcast/topic/impl/reliable/ReliableTopicProxy.java:214
↓ 2 callers
Method
addWithoutEvictionCheck
(Object queryCacheKey, Data valueData)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/DefaultQueryCacheRecordStore.java:106
↓ 2 callers
Method
addedCount
Returns the number of items added to this pipe since creation.
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/Pipe.java:35
↓ 2 callers
Method
addedRecords
()
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:96
↓ 2 callers
Method
additionalCacheConfigSetup
(CacheConfig config, boolean existingConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:401
↓ 2 callers
Method
addrToBlockIndex
(long address)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/HsaHeapMemoryManager.java:77
↓ 2 callers
Method
adjacencyMap
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/PipelineImpl.java:233
↓ 2 callers
Method
adjustExclusionsWithLevel
Adjusts the excluded targets on the given {@code descriptor} if the provided {@code level} is {@link ProbeLevel#DEBUG}. @param descriptor The descrip
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsUtil.java:46
↓ 2 callers
Method
adjustPoolSize
(@Nonnull ProcessingGuarantee externalGuarantee, boolean isSource, int poolSize)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransactionPoolSnapshotUtility.java:100
↓ 2 callers
Method
adjustSequence
(long newSequence)
hazelcast/src/main/java/com/hazelcast/jet/impl/observer/ObservableImpl.java:333
↓ 2 callers
Method
adoptEventFilter
(EventFilter filter, ListenerAdapter listenerAdaptor)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextImpl.java:825
↓ 2 callers
Method
advance
()
hazelcast/src/main/java/com/hazelcast/internal/util/ServiceLoader.java:333
↓ 2 callers
Method
advance
()
hazelcast/src/main/java/com/hazelcast/internal/util/iterator/RestartingMemberIterator.java:78
↓ 2 callers
Method
advance
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:86
↓ 2 callers
Method
advance
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:312
↓ 2 callers
Method
advanceCursor
()
hazelcast/src/test/java/com/hazelcast/jet/core/JobRestartWithSnapshotTest.java:428
↓ 2 callers
Method
advanceOrComplete
(T response, Iterator<InternalCompletableFuture<T>> invocationIterator)
hazelcast/src/main/java/com/hazelcast/internal/util/futures/ChainingFuture.java:63
↓ 2 callers
Method
after
(Credentials credentials, String objectType, String objectName, String methodName, Parameters parameters)
hazelcast/src/main/java/com/hazelcast/security/SecurityInterceptor.java:33
↓ 2 callers
Method
afterClusterStateChange
Called after the cluster state change transaction has completed (successfully or otherwise). Called only on the member that initiated the state change
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:129
↓ 2 callers
Method
afterPut
Called after the put(...) operation is completed. <p> When the in-memory format is not {@code OBJECT}, mutations made to the {@code value} do not affe
hazelcast/src/main/java/com/hazelcast/map/MapInterceptor.java:118
↓ 2 callers
Method
afterRunInternal
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/operations/Backup.java:237
← previous
next →
16,201–16,300 of 147,315, ranked by callers