MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodaddCacheConfig
(String cacheName, CacheConfig cacheConfig)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxyFactory.java:62
↓ 2 callersMethodaddCacheConfigIfAbsent
(CacheConfig<K, V> cacheConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:419
↓ 2 callersMethodaddCachePartitionLostListenerConfig
(CachePartitionLostListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/CacheSimpleConfigReadOnly.java:162
↓ 2 callersMethodaddChild
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 callersMethodaddConditionToQuery
(Query query, String condition, boolean conjunction)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/index/SqlIndexAbstractTest.java:984
↓ 2 callersMethodaddCountIndex
(DelayedEntry entry)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/CyclicWriteBehindQueue.java:176
↓ 2 callersMethodaddCpuRangeToGroup
(CpuGroup group)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/util/ThreadAffinity.java:245
↓ 2 callersMethodaddCustomClasspaths
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 callersMethodaddDefaultBlocklist
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/ReflectionClassNameFilter.java:52
↓ 2 callersMethodaddDiscoveryStrategyConfig
(DiscoveryStrategyConfig discoveryStrategyConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/DiscoveryConfigReadOnly.java:52
↓ 2 callersMethodaddEndpoint
(String endpoint)
hazelcast/src/main/java/com/hazelcast/config/PermissionConfig.java:259
↓ 2 callersMethodaddEntry
(Long id, ScheduledEntry<K, V> entry)
hazelcast/src/main/java/com/hazelcast/internal/util/scheduler/SecondsBasedEntryTaskScheduler.java:317
↓ 2 callersMethodaddEntryListenerConfig
(EntryListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/config/ReplicatedMapConfig.java:154
↓ 2 callersMethodaddEntryListenerInternal
(MapListener listener, K key, boolean includeValue)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/DefaultQueryCache.java:384
↓ 2 callersMethodaddEventData
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 callersMethodaddEventToQueryCache
(Data dataKey, Record record)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:947
↓ 2 callersMethodaddExecutionContextJobId
(long jobId, long executionId, Address coordinator)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionService.java:353
↓ 2 callersMethodaddExpired
(@Nonnull String shardId)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:34
↓ 2 callersMethodaddFilter
(@Nonnull String filterClassName)
hazelcast/src/main/java/com/hazelcast/internal/config/WanReplicationRefReadOnly.java:48
↓ 2 callersMethodaddFilter
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 callersMethodaddForcibly
(DelayedEntry<Data, Object> delayedEntry)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindStore.java:183
↓ 2 callersMethodaddGroupAvailabilityListener
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 callersMethodaddIndex
(IMap<?, ?> map)
hazelcast/src/test/java/com/hazelcast/map/IndexStatsChangingNumberOfMembersTest.java:430
↓ 2 callersMethodaddIndexCofigs
(Collection<IndexConfig> indexConfigs)
hazelcast/src/main/java/com/hazelcast/query/impl/MapIndexInfo.java:43
↓ 2 callersMethodaddIndexConfigToNewMapContainer
(String mapName, int partitionId, IndexRegistry indexRegistry
hazelcast/src/main/java/com/hazelcast/map/impl/MapSplitBrainHandlerService.java:131
↓ 2 callersMethodaddIndexStats
(String mapName, LocalMapStatsImpl localMapStats)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:347
↓ 2 callersMethodaddInfiniteRanges
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 callersMethodaddInner
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 callersMethodaddInternal
(T item)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:553
↓ 2 callersMethodaddInternal
(T item)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/SourceBufferImpl.java:42
↓ 2 callersMethodaddJar
(@Nonnull URL url, @Nullable String id)
hazelcast/src/main/java/com/hazelcast/config/UserCodeNamespaceConfig.java:91
↓ 2 callersMethodaddJarsInZip
(@Nonnull URL url, @Nullable String id)
hazelcast/src/main/java/com/hazelcast/config/UserCodeNamespaceConfig.java:95
↓ 2 callersMethodaddJsonIfSerializable
(JsonObject root, String key, Object value)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/MemberStateImpl.java:369
↓ 2 callersMethodaddListenerDestroyAction
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 callersMethodaddListenerInternal
(Object listener, EventFilter filter, String mapName, boolean local)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextImpl.java:807
↓ 2 callersMethodaddLoadedListener
(IMap map, final CountDownLatch counter)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/LoadAllTest.java:237
↓ 2 callersMethodaddLocalMigrationListener
(MigrationListener migrationListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:138
↓ 2 callersMethodaddLockConfig
(FencedLockConfig lockConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicCPSubsystemConfig.java:97
↓ 2 callersMethodaddLockConfig
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 callersMethodaddMemberPrefixFn
(@Nonnull Member member)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobMetricsUtil.java:52
↓ 2 callersMethodaddMessageListenerConfig
(ListenerConfig listenerConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/TopicConfigReadOnly.java:61
↓ 2 callersMethodaddMessageListenerConfig
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 callersMethodaddMessageListenerInternal
(@Nonnull MessageListener listener)
hazelcast/src/main/java/com/hazelcast/topic/impl/TopicProxySupport.java:102
↓ 2 callersMethodaddMigrationListenerAsync
(MigrationListener migrationListener)
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:136
↓ 2 callersMethodaddMulti
(String name, Collection<String> values)
hazelcast/src/main/java/com/hazelcast/aws/Filter.java:38
↓ 2 callersMethodaddMulticastListener
(MulticastListener multicastListener)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MulticastService.java:178
↓ 2 callersMethodaddNearCacheStats
(String mapName, LocalMapStatsImpl localMapStats, LocalMapOnDemandCalculate
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:333
↓ 2 callersMethodaddNewAddressToAddressMap
(int id, String host, int initialPort)
hazelcast/src/test/java/com/hazelcast/test/TestHazelcastInstanceFactory.java:517
↓ 2 callersMethodaddNewWorkerIfRequired
()
hazelcast/src/main/java/com/hazelcast/internal/util/executor/CachedExecutorServiceDelegate.java:131
↓ 2 callersMethodaddNode
(PartitionReplica replica)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:404
↓ 2 callersMethodaddOperation
(CollectionTxnOperation operation)
hazelcast/src/main/java/com/hazelcast/collection/impl/txncollection/CollectionTransactionLogRecord.java:80
↓ 2 callersMethodaddOutboundPortDefinition
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 callersMethodaddOwnInterfaces
(Class<?> clazz, Collection<Class<?>> allInterfaces)
hazelcast/src/main/java/com/hazelcast/internal/nio/ClassLoaderUtil.java:387
↓ 2 callersMethodaddPart
(List<String> list, StringBuilder sb, boolean trim)
hazelcast-build-utils/src/main/java/com/hazelcast/buildutils/ElementParser.java:106
↓ 2 callersMethodaddPartitionLostListenerInternal
(MapPartitionLostListener listener)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:1282
↓ 2 callersMethodaddPermissionForTable
(RelOptTable t, String action)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/CalciteSqlOptimizerImpl.java:736
↓ 2 callersMethodaddPersistence
(long duration, int writtenBytes, int keyCount)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImpl.java:250
↓ 2 callersMethodaddPortableFactories
(Config config)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryBasicTest.java:995
↓ 2 callersMethodaddPortableFactory
(int id, PortableFactory factory)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DefaultSerializationServiceBuilder.java:151
↓ 2 callersMethodaddRealmReference
(XmlGenerator gen, String refName, String realmName)
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:288
↓ 2 callersMethodaddRegistration
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 callersMethodaddReplicaSyncPermits
(InternalPartitionServiceImpl partitionService, int k)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionReplicaStateCheckerTest.java:240
↓ 2 callersMethodaddResources
(List<DataConnectionResource> resources, MongoDatabase database)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnection.java:237
↓ 2 callersMethodaddResultsOfPredicate
(List<Future<Result>> futures, Result result, PartitionIdSet unfinished
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryEngineImpl.java:208
↓ 2 callersMethodaddRow
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 callersMethodaddSecurityFeatureInfo
(StringBuilder sb, String feature)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeSecurityBanner.java:163
↓ 2 callersMethodaddSecurityInterceptorConfig
(SecurityInterceptorConfig interceptorConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicSecurityConfig.java:51
↓ 2 callersMethodaddSemaphoreConfig
(SemaphoreConfig semaphoreConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicCPSubsystemConfig.java:87
↓ 2 callersMethodaddSemaphoreConfig
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 callersMethodaddStatsOfBackupReplica
(RecordStore recordStore, LocalMapOnDemandCalculatedStats onDemandStats)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:256
↓ 2 callersMethodaddStatsOfPrimaryReplica
(RecordStore recordStore, LocalMapOnDemandCalculatedStats onD
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:233
↓ 2 callersMethodaddStructureStats
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 callersMethodaddTask
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 callersMethodaddTemporaryMemberAddress
(Address memberAddress)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/TcpIpJoiner.java:477
↓ 2 callersMethodaddToQueue
(Queue<? super E> queue, int capacity, E o)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:94
↓ 2 callersMethodaddWanReplicationConfig
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 callersMethodaddWhitespace
(Node node)
hazelcast/src/test/java/com/hazelcast/config/XmlOnlyConfigBuilderTest.java:305
↓ 2 callersMethodaddWindowBounds
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 callersMethodaddWithBackoff
(Collection<ReliableTopicMessage> messages)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReliableTopicProxy.java:148
↓ 2 callersMethodaddWithBackoff
(Collection<ReliableTopicMessage> messages)
hazelcast/src/main/java/com/hazelcast/topic/impl/reliable/ReliableTopicProxy.java:214
↓ 2 callersMethodaddWithoutEvictionCheck
(Object queryCacheKey, Data valueData)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/DefaultQueryCacheRecordStore.java:106
↓ 2 callersMethodaddedCount
Returns the number of items added to this pipe since creation.
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/Pipe.java:35
↓ 2 callersMethodaddedRecords
()
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:96
↓ 2 callersMethodadditionalCacheConfigSetup
(CacheConfig config, boolean existingConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:401
↓ 2 callersMethodaddrToBlockIndex
(long address)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/HsaHeapMemoryManager.java:77
↓ 2 callersMethodadjacencyMap
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/PipelineImpl.java:233
↓ 2 callersMethodadjustExclusionsWithLevel
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 callersMethodadjustPoolSize
(@Nonnull ProcessingGuarantee externalGuarantee, boolean isSource, int poolSize)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransactionPoolSnapshotUtility.java:100
↓ 2 callersMethodadjustSequence
(long newSequence)
hazelcast/src/main/java/com/hazelcast/jet/impl/observer/ObservableImpl.java:333
↓ 2 callersMethodadoptEventFilter
(EventFilter filter, ListenerAdapter listenerAdaptor)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextImpl.java:825
↓ 2 callersMethodadvance
()
hazelcast/src/main/java/com/hazelcast/internal/util/ServiceLoader.java:333
↓ 2 callersMethodadvance
()
hazelcast/src/main/java/com/hazelcast/internal/util/iterator/RestartingMemberIterator.java:78
↓ 2 callersMethodadvance
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:86
↓ 2 callersMethodadvance
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:312
↓ 2 callersMethodadvanceCursor
()
hazelcast/src/test/java/com/hazelcast/jet/core/JobRestartWithSnapshotTest.java:428
↓ 2 callersMethodadvanceOrComplete
(T response, Iterator<InternalCompletableFuture<T>> invocationIterator)
hazelcast/src/main/java/com/hazelcast/internal/util/futures/ChainingFuture.java:63
↓ 2 callersMethodafter
(Credentials credentials, String objectType, String objectName, String methodName, Parameters parameters)
hazelcast/src/main/java/com/hazelcast/security/SecurityInterceptor.java:33
↓ 2 callersMethodafterClusterStateChange
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 callersMethodafterPut
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 callersMethodafterRunInternal
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/operations/Backup.java:237
← previousnext →16,201–16,300 of 147,315, ranked by callers