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
↓ 3 callers
Method
assertMigrationSourceRollback
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:434
↓ 3 callers
Method
assertMinAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:344
↓ 3 callers
Method
assertMinByAggregatorAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:320
↓ 3 callers
Method
assertNearCacheContent
Asserts the values of the Near Cache itself. @param context the {@link NearCacheTestContext} to retrieve the Near Cache from @param size the numbe
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:279
↓ 3 callers
Method
assertNearCacheInvalidation_whenMaxSizeExceeded
(NearCacheConfig config)
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/ClientMapNearCacheTest.java:1256
↓ 3 callers
Method
assertNearCacheInvalidations
Asserts the number of Near Cache invalidations. @param context the given {@link NearCacheTestContext} to retrieve the {@link NearCacheStats} fr
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:391
↓ 3 callers
Method
assertNearCacheRecordStates
(DefaultNearCache nearCache, int keySpace)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/MapNearCacheRecordStateStressTest.java:158
↓ 3 callers
Method
assertNearCacheReference
Asserts that the Near Cache contains the same reference than the given value, when in-memory-format is OBJECT. @param context the {@link NearCacheTes
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:298
↓ 3 callers
Method
assertNoChannelLeak
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioChannelMemoryLeakTest.java:96
↓ 3 callers
Method
assertNoMBeanLeftovers
()
hazelcast/src/test/java/com/hazelcast/cache/jsr/JsrTestUtil.java:202
↓ 3 callers
Method
assertNoMBeans
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTestHelper.java:69
↓ 3 callers
Method
assertNonMemberNetworkStatsAreZeroFromMetrics
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AdvancedNetworkStatsIntegrationTest.java:188
↓ 3 callers
Method
assertNotProbeExist
(ProbeLevel probeLevel, ProbeLevel minimumLevel)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/ProbeLevelTest.java:72
↓ 3 callers
Method
assertPacketEquals
(Packet originalPacket, Packet clonedPacket)
hazelcast/src/test/java/com/hazelcast/nio/PacketIOHelperTest.java:190
↓ 3 callers
Method
assertParamsEquals
(Object[] array, Object... expected)
hazelcast/src/test/java/com/hazelcast/internal/util/UnmodifiableLazyListTest.java:275
↓ 3 callers
Method
assertPartitionLostEventEventually
(final EventCollectingPartitionLostListener listener, final int partitionId)
hazelcast/src/test/java/com/hazelcast/client/partitionservice/ClientPartitionLostListenerTest.java:174
↓ 3 callers
Method
assertPeekOutput
()
hazelcast/src/test/java/com/hazelcast/jet/core/PeekingWrapperTest.java:290
↓ 3 callers
Method
assertPeekSnapshot
()
hazelcast/src/test/java/com/hazelcast/jet/core/PeekingWrapperTest.java:337
↓ 3 callers
Method
assertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/map/impl/LatencyTrackingMapLoaderTest.java:102
↓ 3 callers
Method
assertPropertyNotSet
(String key)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:99
↓ 3 callers
Method
assertPrunability
(int partitionCountUsed)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SpecificPartitionsImapReaderPmsTest.java:295
↓ 3 callers
Method
assertRecoversXid
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXACompatibilityTest.java:169
↓ 3 callers
Method
assertRepeatedSerialisationGivesSameByteArrays
(SerializationService ss, Portable p)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:284
↓ 3 callers
Method
assertReplicationSlotActive
()
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcListenBeforeExistsIntegrationTest.java:230
↓ 3 callers
Method
assertRequiresPrepare
(int recordCount, boolean expected)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseTest.java:119
↓ 3 callers
Method
assertResultEventually
(Function<Integer, Stream<? extends String>> transformFn, int numItems)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/AsyncTransformUsingServiceP_IntegrationTest.java:232
↓ 3 callers
Method
assertResultMap
(Map<Integer, Object> resultMap)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:938
↓ 3 callers
Method
assertResultValue
(String label, ValueSerializationCountingData expected, ValueSerializationCountingData actual)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheSerializationCountTest.java:267
↓ 3 callers
Method
assertRolledBack
(TransactionImpl tx)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseIT.java:77
↓ 3 callers
Method
assertSafeEventually
(Collection<HazelcastInstance> instances)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionServiceSafetyCheckTest.java:271
↓ 3 callers
Method
assertSecondary
(Addresses addresses, Address... expected)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProviderTest.java:120
↓ 3 callers
Method
assertSequenceNumbersEqual
(Map<Integer, Long> source, Map<Integer, Long> destination)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/invalidation/MemberMapInvalidationMetaDataMigrationTest.java:314
↓ 3 callers
Method
assertSnapshotMBeans
(Job job, String vertex, long expectedSnapshotKeys, boolean snapshotBytesExists)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobSnapshotMetricsTest.java:111
↓ 3 callers
Method
assertSplitBrainMessagesCount
(final int clusterSize, final HazelcastInstance[] instances, fi
hazelcast/src/test/java/com/hazelcast/cluster/SlowMulticastJoinTest.java:124
↓ 3 callers
Method
assertSqlDatesEqual
(java.sql.Date firstDate, java.sql.Date secondDate)
hazelcast/src/test/java/com/hazelcast/query/impl/DateHelperTest.java:96
↓ 3 callers
Method
assertSqlTimesEqual
(Time firstTime, Time secondTime)
hazelcast/src/test/java/com/hazelcast/query/impl/DateHelperTest.java:247
↓ 3 callers
Method
assertTaskExecutedItsLogic
()
hazelcast/src/test/java/com/hazelcast/executor/CompletableFutureTest.java:305
↓ 3 callers
Method
assertThatDeserializedFunctionCreates
(Object deserialized, Class<?> expectedType)
hazelcast/src/test/java/com/hazelcast/jet/json/impl/JsonUtilImplTest.java:181
↓ 3 callers
Method
assertThatNoCacheEvictionHappened
(ICache cache)
hazelcast/src/test/java/com/hazelcast/cache/CacheTestSupport.java:150
↓ 3 callers
Method
assertThrowsJetException
(Job job, String messageFragment)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisFailureTest.java:268
↓ 3 callers
Method
assertThrowsNPE
(ConsumerEx<ClientService> method)
hazelcast/src/test/java/com/hazelcast/client/AbstractClientServiceNullTest.java:37
↓ 3 callers
Method
assertTimestampsEqual
(Timestamp firstTimestamp, Timestamp secondTimestamp)
hazelcast/src/test/java/com/hazelcast/query/impl/DateHelperTest.java:178
↓ 3 callers
Method
assertToKey
(String key, Object object)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/OverloadedConnectionsPluginTest.java:122
↓ 3 callers
Method
assertTopicEventually
(String name, String sql, Map<PersonId, Person> expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlPojoTest.java:286
↓ 3 callers
Method
assertTrackingFileContents
(String pattern, Consumer<String> contentAssertion)
hazelcast/src/test/java/com/hazelcast/instance/InstanceTrackingInfoTest.java:121
↓ 3 callers
Method
assertTrueKV
(boolean actual, long key, long value)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/Long2LongMapHsaTest.java:455
↓ 3 callers
Method
assertTwoStageGlobalAggregation
(int i)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/RebalanceBatchStageTest.java:678
↓ 3 callers
Method
assertTxLogState
(UUID txId, Transaction.State state)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionManagerServiceImplTest.java:106
↓ 3 callers
Method
assertUuid
(String jsonResult, UUID expectedUuid)
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:229
↓ 3 callers
Method
assertValid
(WaitSet waitSet, BlockedOperation operation, boolean valid)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/WaitSetTest.java:186
↓ 3 callers
Method
assertValuesSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheMethodsWithPredicateTest.java:329
↓ 3 callers
Method
assertValuesSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheMethodsWithPredicateTest.java:383
↓ 3 callers
Method
assertVertexCount
(DAG dag, int expectedCount)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamStageTest.java:381
↓ 3 callers
Method
assertWBStoreRunsOnPartitionThread
(State state)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/IMapOpStep.java:83
↓ 3 callers
Method
assertWaitingOperationCountEventually
(int expectedOpsCount, HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1412
↓ 3 callers
Method
assertionSink
Returns a builder object that offers a step-by-step fluent API to build an assertion {@link Sink} for the Pipeline API. An assertion sink is typically
hazelcast/src/main/java/com/hazelcast/jet/pipeline/test/AssertionSinkBuilder.java:93
↓ 3 callers
Method
assignOutOfRangeNodeId
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/flakeidgen/impl/FlakeIdGenerator_NodeIdOverflowIntegrationTest.java:80
↓ 3 callers
Method
assignOverflowedNodeId
(HazelcastInstance instance2)
hazelcast/src/test/java/com/hazelcast/client/flakeidgen/impl/FlakeIdGenerator_NodeIdOverflowIntegrationTest.java:104
↓ 3 callers
Method
assumeHadoopSupportsIbmPlatform
()
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1595
↓ 3 callers
Method
assumeThatMethodIsAvailable
Assumes that the {@link DataStructureAdapter} created by the Near Cache test supports a given {@link DataStructureAdapterMethod}. @param method the {
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheSerializationCountTest.java:137
↓ 3 callers
Method
attachAll
Attaches all the files/directories in the supplied map, as if by calling {@link #attachDirectory(File, String) attachDirectory(dir, id)} for every ent
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1061
↓ 3 callers
Method
attachTo
(InternalIndex delegate)
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalQueryContextWithStats.java:78
↓ 3 callers
Method
authenticateAndAssert
(AuthenticationStatus status, byte serVersion, boolean useWrongClusterName, String clusterName)
hazelcast/src/test/java/com/hazelcast/client/AuthenticationInformationLeakTest.java:156
↓ 3 callers
Method
availabilityZoneEc2
()
hazelcast/src/main/java/com/hazelcast/aws/AwsMetadataApi.java:80
↓ 3 callers
Method
availabilityZoneEcs
()
hazelcast/src/main/java/com/hazelcast/aws/AwsMetadataApi.java:85
↓ 3 callers
Method
availableReplicaSyncPermits
Returns the number of available permits.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionReplicaManager.java:484
↓ 3 callers
Method
avroFile
(Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/SqlAvroTest.java:323
↓ 3 callers
Method
awaitAndForceShutdown
(Map<?, ? extends ExecutorService> executorServiceMap)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/impl/ExecutionServiceImpl.java:341
↓ 3 callers
Method
awaitExecutorTermination
(String name, ExecutorService executor, ILogger logger)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientExecutionServiceImpl.java:90
↓ 3 callers
Method
awaitFirstIteration
()
hazelcast/src/test/java/com/hazelcast/cache/CacheBasicAbstractTest.java:816
↓ 3 callers
Method
awaitOnlyOneJobIsRunning
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/PartialJobMetricsCollectionTest.java:172
↓ 3 callers
Method
awaitState
Await the result, throwing an error if something went wrong.
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientResult.java:317
↓ 3 callers
Method
axes
Generates combinations of parameters and outputs them in the horrible JUnit format
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/extractor/AbstractExtractionTest.java:178
↓ 3 callers
Method
badPathException
(String path)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/extract/QueryPath.java:111
↓ 3 callers
Method
base64encodeUrlSafe
(String data)
hazelcast/src/main/java/com/hazelcast/gcp/GcpAuthenticator.java:131
↓ 3 callers
Method
batchDag
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:117
↓ 3 callers
Method
batchPipeline
()
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobLifecycleMetricsTest.java:307
↓ 3 callers
Method
beforeClusterStateChange
Called before starting a cluster state change transaction. Called only on the member that initiated the state change. @param currState the state befo
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:336
↓ 3 callers
Method
beforeRun
()
hazelcast/src/test/java/com/hazelcast/cluster/impl/DiscoverySPIJoinTest.java:95
↓ 3 callers
Method
begin
Begins the transaction. The method will be called before the transaction is returned from {@link #activeTransaction()} for the first time after creati
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:273
↓ 3 callers
Method
benchmark
(String label, Runnable run)
hazelcast/src/test/java/com/hazelcast/jet/benchmark/WordCountTest.java:212
↓ 3 callers
Method
blacklist
Adds an address to the blacklist. Blacklist is useful if a node should ignore another node, e.g. when the cluster name of 2 machines is not the same,
hazelcast/src/main/java/com/hazelcast/internal/cluster/Joiner.java:51
↓ 3 callers
Method
blockNewConnection
(Address address)
hazelcast/src/test/java/com/hazelcast/internal/server/FirewallingServer.java:195
↓ 3 callers
Method
bouncingIntervalSeconds
(int bouncingIntervalSeconds)
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:543
↓ 3 callers
Method
broadcastConfigAsync
(IdentifiedDataSerializable config)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ClusterWideConfigurationService.java:256
↓ 3 callers
Method
bucketCount
()
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:99
↓ 3 callers
Method
build
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DeserializedSchemaBoundGenericRecordBuilder.java:44
↓ 3 callers
Method
buildBatch
( @Nonnull AggregateOperation<A, ? extends R> aggrOp, @Nonnull BiFunctionEx<? super K,
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/GrAggBuilder.java:95
↓ 3 callers
Method
buildHttpRequest
(String method)
hazelcast/src/main/java/com/hazelcast/spi/utils/RestClient.java:190
↓ 3 callers
Method
buildKubernetesApiUrlProvider
()
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:162
↓ 3 callers
Method
buildNode
(YamlNode parent, String nodeName, Object sourceNode)
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlDomBuilder.java:61
↓ 3 callers
Method
buildQuery
(Predicate predicate)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/map/AbstractMapQueryMessageTask.java:185
↓ 3 callers
Method
buildReplicatedRecord
(K key, V value, long ttlMillis)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/AbstractReplicatedRecordStore.java:343
↓ 3 callers
Method
bulkWrite
(List<? extends ClientNamespacedWriteModel> models)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/CloseableMongoClient.java:232
↓ 3 callers
Method
byteBufferToBytes
(ByteBuffer buffer)
hazelcast/src/test/java/com/hazelcast/instance/impl/TestUtil.java:269
↓ 3 callers
Method
bytesToHex
Convert byte[] to hexadecimal string
hazelcast/src/main/java/com/hazelcast/internal/util/Sha256Util.java:83
↓ 3 callers
Method
bytesTransceived
()
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioThread.java:153
↓ 3 callers
Method
bytesWritten
Returns current count of bytes written into the Channel. The read values might not reflect the most recent value. @return count of written bytes
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:276
↓ 3 callers
Method
bytesWrittenSoFar
(BufferObjectDataOutput out)
hazelcast/src/main/java/com/hazelcast/internal/partition/ChunkSerDeHelper.java:177
↓ 3 callers
Method
calculateElapsed
(final long lastRepartitionNanos)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationTimer.java:43
← previous
next →
13,501–13,600 of 147,315, ranked by callers