MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethodnewClientConfig
()
hazelcast/src/test/java/com/hazelcast/client/ClientTimeoutTest.java:126
↓ 3 callersMethodnewClientConfig
()
hazelcast/src/test/java/com/hazelcast/client/ClientBackupAckTest.java:123
↓ 3 callersMethodnewClientConfigWithQueryCache
(String mapName, String queryCacheName)
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheCreateDestroyTest.java:107
↓ 3 callersMethodnewConfig
(String trustedInterface)
hazelcast/src/test/java/com/hazelcast/cluster/SlowMulticastJoinTest.java:139
↓ 3 callersMethodnewConfigWithMigrationAwareService
()
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/NoMigrationClusterStateTest.java:247
↓ 3 callersMethodnewConfigWithQueryCache
(String mapName, String queryCacheName)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheCreateDestroyTest.java:122
↓ 3 callersMethodnewConnection
(final EndpointQualifier qualifier, SocketChannel socketChannel)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerAcceptor.java:285
↓ 3 callersMethodnewEnabledBackPressureService
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/BackpressureRegulatorTest.java:289
↓ 3 callersMethodnewEndToEndConstructor
@param request see {@link QueryCacheRequest} @return a new instance of {@link QueryCacheEndToEndConstructor}
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/SubscriberContext.java:89
↓ 3 callersMethodnewEvictionConfig
(Integer maxSize, boolean isIMap)
hazelcast-spring/src/test/java/com/hazelcast/spring/config/ConfigFactoryTest.java:159
↓ 3 callersMethodnewEvictionConfigWithEvictionPolicy
(EvictionPolicy evictionPolicy, boolean isIMap)
hazelcast-spring/src/test/java/com/hazelcast/spring/config/ConfigFactoryTest.java:154
↓ 3 callersMethodnewEvictionConfigWithMaxSizePolicy
(MaxSizePolicy maxSizePolicy, boolean isIMap)
hazelcast-spring/src/test/java/com/hazelcast/spring/config/ConfigFactoryTest.java:149
↓ 3 callersMethodnewException
()
hazelcast/src/main/java/com/hazelcast/query/impl/getters/policy/NoAccessReflectiveAttributeLookupPolicy.java:50
↓ 3 callersMethodnewHashEntry
(K key, int hash, HashEntry<K, V> next, V value)
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:613
↓ 3 callersMethodnewHashMap
(EndpointQualifier member, Address address)
hazelcast/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java:224
↓ 3 callersMethodnewHazelcastFailoverClient
Creates a client with cluster switch capability. Client will try to connect to alternative clusters according to {@link ClientFailoverConfig} when it
hazelcast/src/main/java/com/hazelcast/client/HazelcastClient.java:166
↓ 3 callersMethodnewInstances
(Config config)
hazelcast/src/test/java/com/hazelcast/cardinality/CardinalityEstimatorAbstractTest.java:71
↓ 3 callersMethodnewInterface
(String name)
hazelcast/src/test/java/com/hazelcast/internal/util/ServiceLoaderTest.java:297
↓ 3 callersMethodnewJob
(DAG dag)
hazelcast/src/test/java/com/hazelcast/jet/core/ExecutionLifecycle_RestartableExceptionTest.java:187
↓ 3 callersMethodnewMapStoredConfig
(MapStore store, int writeDelaySeconds)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindFlushTest.java:231
↓ 3 callersMethodnewMetricsRegistry
()
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnection_AbstractTest.java:119
↓ 3 callersMethodnewMockClassSource
()
hazelcast/src/test/java/com/hazelcast/internal/usercodedeployment/impl/ClassDataProviderTest.java:85
↓ 3 callersMethodnewMockEntry
(Object attributeValue)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/NotEqualPredicateTest.java:112
↓ 3 callersMethodnewMockTcpServer
(MetricsRegistry metricsRegistry)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnection_AbstractTest.java:123
↓ 3 callersMethodnewObjectInputStream
(final ClassLoader classLoader, ClassNameFilter classFilter,
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:316
↓ 3 callersMethodnewPrepareOperation
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionLogRecord.java:42
↓ 3 callersMethodnewQueryCacheConfig
(String cacheName)
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheDestroyResourcesTest.java:87
↓ 3 callersMethodnewQueryCacheConfig
(String cacheName)
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheClientContextTest.java:80
↓ 3 callersMethodnewQueryCacheRequest
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheRequest.java:48
↓ 3 callersMethodnewQueryEntry
(Data key, Object value)
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:116
↓ 3 callersMethodnewQueue
()
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/QueueIteratorTest.java:106
↓ 3 callersMethodnewResponsePacket
(byte[] bytes, boolean urgent)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OutboundResponseHandler.java:202
↓ 3 callersMethodnewSelector
Creates a new Selector and will optimize it if possible. @return the created Selector. @throws NullPointerException if logger is null.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/SelectorOptimizer.java:56
↓ 3 callersMethodnewServerSocket
(Reactor reactor)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/net/AsyncSocketTest.java:270
↓ 3 callersMethodnewSetOf
(Collection<T> previous)
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:382
↓ 3 callersMethodnewestSequence
Returns the sequence of the newest event stored in the event journal. @param namespace the object namespace @param partitionId the partition ID of
hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournal.java:47
↓ 3 callersMethodnext
()
hazelcast/src/main/java/com/hazelcast/client/util/RoundRobinLB.java:43
↓ 3 callersMethodnext
()
hazelcast/src/main/java/com/hazelcast/client/util/RandomLB.java:31
↓ 3 callersMethodnext
()
hazelcast/src/main/java/com/hazelcast/jet/impl/observer/ObservableImpl.java:203
↓ 3 callersMethodnextAvailableOrdinal
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/Planner.java:338
↓ 3 callersMethodnextDataMember
()
hazelcast/src/main/java/com/hazelcast/client/util/RoundRobinLB.java:48
↓ 3 callersMethodnextDataMember
()
hazelcast/src/main/java/com/hazelcast/client/util/RandomLB.java:36
↓ 3 callersMethodnextExpirationTime
(long ttlMillis, long maxIdleMillis, long now, long lastUpdateTime)
hazelcast/src/main/java/com/hazelcast/map/impl/ExpirationTimeSetter.java:32
↓ 3 callersMethodnextId
Returns the next ID that can be used for uniquely identifying queue items
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:1085
↓ 3 callersMethodnoStats
()
hazelcast/src/test/java/com/hazelcast/map/LocalIndexStatsTest.java:697
↓ 3 callersMethodnodesCanShutDown_whenClusterState_changesTo
(ClusterState state)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/AdvancedClusterStateTest.java:582
↓ 3 callersMethodnormalize
Normalize the given value to a value returned by this instance. If the value doesn't match the type expected by the converter, an exception is thrown.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:232
↓ 3 callersMethodnotReady
(String ip, Integer port)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesClientTest.java:1011
↓ 3 callersMethodnotifyErrorResponse
(long callId, Object cause, Address sender)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/InboundResponseHandler.java:133
↓ 3 callersMethodnotifyMigrationAwarePublishers
(Consumer<WanMigrationAwarePublisher> publisherConsumer)
hazelcast/src/main/java/com/hazelcast/wan/impl/WanReplicationServiceImpl.java:418
↓ 3 callersMethodnullsFirst
{@code Serializable} variant of {@link Comparator#nullsFirst(Comparator) java.util.Comparator#nullsFirst(Comparator)}. @param <T> the type of the ele
hazelcast/src/main/java/com/hazelcast/function/ComparatorEx.java:87
↓ 3 callersMethodnullsLast
{@code Serializable} variant of {@link Comparator#nullsLast(Comparator) java.util.Comparator#nullsLast(Comparator)}. @param <T> the type of the eleme
hazelcast/src/main/java/com/hazelcast/function/ComparatorEx.java:109
↓ 3 callersMethodnumBytes
()
hazelcast/src/main/java/com/hazelcast/jet/impl/SnapshotValidationRecord.java:61
↓ 3 callersMethodnumeric
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionTypes.java:91
↓ 3 callersMethodobjectNames
(Class<? extends SqlCatalogObject> clazz)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/RelationsStorage.java:113
↓ 3 callersMethodobjectType
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/Mapping.java:101
↓ 3 callersMethodobjectType
Object type, must match the name of supported types for given connector.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/SqlConnector.java:692
↓ 3 callersMethodobtrudeValue
(Void value)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/NonCompletableFuture.java:60
↓ 3 callersMethodof
(ListenerConfig config, SerializationService serializationService, @
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/ListenerConfigHolder.java:211
↓ 3 callersMethodof
(List<Map.Entry<Integer, Map.Entry>> anchorList, SerializationServic
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/AnchorDataListHolder.java:60
↓ 3 callersMethodof
(Predicate<K, V> predicate, SerializationService serializati
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/PagingPredicateHolder.java:128
↓ 3 callersMethodof
(CacheConfig<K, V> config, SerializationService serializationService)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/CacheConfigHolder.java:287
↓ 3 callersMethodof
(T initialState)
hazelcast/src/main/java/com/hazelcast/internal/util/StateMachine.java:41
↓ 3 callersMethodof
(X element1, Y element2, Z element3)
hazelcast/src/main/java/com/hazelcast/internal/util/TriTuple.java:41
↓ 3 callersMethodofferToConveyor
(Object item)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ConveyorCollector.java:54
↓ 3 callersMethodoffset
(Map<String, V> partition)
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/JetSourceOffsetStorageReader.java:37
↓ 3 callersMethodoldestSequence
Returns the sequence of the oldest event stored in the event journal. @param namespace the object namespace @param partitionId the partition ID of
hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournal.java:57
↓ 3 callersMethodonClusterConnectionFailed
Calls {@link ClientConnectionProcessListener#clusterConnectionFailed(String)} on all listeners.
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListenerRegistry.java:150
↓ 3 callersMethodonClusterStateChange
(ClusterState newState)
hazelcast/src/main/java/com/hazelcast/internal/eviction/ExpirationManager.java:135
↓ 3 callersMethodonComplete
(MigrationInfo promotion)
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PromotionCommitOperation.java:374
↓ 3 callersMethodonComplete
(MigrationInfo migration)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:1217
↓ 3 callersMethodonCompleted
()
extensions/grpc/src/test/java/com/hazelcast/jet/grpc/GrpcServiceTest.java:470
↓ 3 callersMethodonConfigRegistered
Called when a new {@link MapConfig} object is created locally.
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigListener.java:36
↓ 3 callersMethodonDestroy
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:143
↓ 3 callersMethodonDetected
Called when concurrency is detected. <p> This call is thread-safe.
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrencyDetection.java:53
↓ 3 callersMethodonError
Is called when the {@link #process()} throws a {@link Throwable}. <p> This method should only be called by the current {@link NioThread owner}. <p> Th
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioPipeline.java:255
↓ 3 callersMethodonEvict
Called when an entry is evicted. @param key the key @param value the old value
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheRSMutationObserver.java:59
↓ 3 callersMethodonEvict
Called when an {@link Evictable} entry is evicted. @param evictedEntryAccessor Accessor of the {@link Evictable} entry that is evicted. @param evicte
hazelcast/src/main/java/com/hazelcast/internal/eviction/EvictionListener.java:39
↓ 3 callersMethodonEvictRecord
Called when a record is evicted from the observed {@link RecordStore} @param key The key of the record @param record The record @param backup {@c
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/MutationObserver.java:84
↓ 3 callersMethodonExpire
Called when an entry is expired. @param key the key @param value the old value
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheRSMutationObserver.java:67
↓ 3 callersMethodonInvocationException
Called when an <code>Exception</code>/<code>Error</code> is thrown during an invocation. Invocation process will continue, it will retry or fail accor
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:589
↓ 3 callersMethodonMemberListChange
Called synchronously when member list changes
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:358
↓ 3 callersMethodonMigrationRollback
(MigrationParticipant participant, MigrationInfo migration)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationInterceptor.java:50
↓ 3 callersMethodonMigrationStart
(MigrationParticipant participant, MigrationInfo migration)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationInterceptor.java:41
↓ 3 callersMethodonNextPage
(SqlPage page)
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientResult.java:425
↓ 3 callersMethodonOperationFailure
(Operation op, Throwable e)
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PartitionReplicaSyncResponse.java:257
↓ 3 callersMethodonPingLost
Notifies the {@link SplitBrainProtectionFunction} of ping loss. @param member member which was not pinged successfully
hazelcast/src/main/java/com/hazelcast/splitbrainprotection/PingAware.java:34
↓ 3 callersMethodonPingRestored
Notifies the {@link SplitBrainProtectionFunction} of a successful ping after one or more pings to that member were lost. @param member member which w
hazelcast/src/main/java/com/hazelcast/splitbrainprotection/PingAware.java:41
↓ 3 callersMethodonPutInternal
(Data dataKey, Record record)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/JsonMetadataMutationObserver.java:120
↓ 3 callersMethodonRead
()
hazelcast/src/main/java/com/hazelcast/internal/nio/ascii/TextDecoder.java:84
↓ 3 callersMethodonRemoteCallFailure
()
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/RemoteCallHook.java:44
↓ 3 callersMethodonRemoteCallSuccess
(Operation remoteCall)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/RemoteCallHook.java:40
↓ 3 callersMethodonRemove
(Data key, Object value, UUID source, boolean getValue, R record, boolean removed)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1560
↓ 3 callersMethodonRemoveError
(Data key, Object value, UUID source, boolean getValue, R record, boolean rem
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1564
↓ 3 callersMethodonRemoveRecord
Called when a record is removed from the observed {@link RecordStore} @param key The key of the record @param record The record @param backup {@c
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/MutationObserver.java:75
↓ 3 callersMethodonReplace
(Data key, Object oldValue, Object newValue, ExpiryPolicy expiryPolicy, UUID sour
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1417
↓ 3 callersMethodonReplace
(boolean isGet, long startNanos, Object response)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/CacheStatsHandler.java:41
↓ 3 callersMethodonReplaceError
(Data key, Object oldValue, Object newValue, ExpiryPolicy expiryPolicy, UUID source,
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1422
↓ 3 callersMethodonReplicaSync
(ReplicaSyncEvent syncEvent)
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngineImpl.java:547
↓ 3 callersMethodonTableChanged
Invoked on registered listeners after update/removal of a {@see Table}.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/TableResolver.java:65
← previousnext →15,201–15,300 of 147,315, ranked by callers