MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethodassertMigrationSourceRollback
(final MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:434
↓ 3 callersMethodassertMinAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:344
↓ 3 callersMethodassertMinByAggregatorAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:320
↓ 3 callersMethodassertNearCacheContent
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 callersMethodassertNearCacheInvalidation_whenMaxSizeExceeded
(NearCacheConfig config)
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/ClientMapNearCacheTest.java:1256
↓ 3 callersMethodassertNearCacheInvalidations
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 callersMethodassertNearCacheRecordStates
(DefaultNearCache nearCache, int keySpace)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/MapNearCacheRecordStateStressTest.java:158
↓ 3 callersMethodassertNearCacheReference
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 callersMethodassertNoChannelLeak
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioChannelMemoryLeakTest.java:96
↓ 3 callersMethodassertNoMBeanLeftovers
()
hazelcast/src/test/java/com/hazelcast/cache/jsr/JsrTestUtil.java:202
↓ 3 callersMethodassertNoMBeans
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTestHelper.java:69
↓ 3 callersMethodassertNonMemberNetworkStatsAreZeroFromMetrics
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AdvancedNetworkStatsIntegrationTest.java:188
↓ 3 callersMethodassertNotProbeExist
(ProbeLevel probeLevel, ProbeLevel minimumLevel)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/ProbeLevelTest.java:72
↓ 3 callersMethodassertPacketEquals
(Packet originalPacket, Packet clonedPacket)
hazelcast/src/test/java/com/hazelcast/nio/PacketIOHelperTest.java:190
↓ 3 callersMethodassertParamsEquals
(Object[] array, Object... expected)
hazelcast/src/test/java/com/hazelcast/internal/util/UnmodifiableLazyListTest.java:275
↓ 3 callersMethodassertPartitionLostEventEventually
(final EventCollectingPartitionLostListener listener, final int partitionId)
hazelcast/src/test/java/com/hazelcast/client/partitionservice/ClientPartitionLostListenerTest.java:174
↓ 3 callersMethodassertPeekOutput
()
hazelcast/src/test/java/com/hazelcast/jet/core/PeekingWrapperTest.java:290
↓ 3 callersMethodassertPeekSnapshot
()
hazelcast/src/test/java/com/hazelcast/jet/core/PeekingWrapperTest.java:337
↓ 3 callersMethodassertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/map/impl/LatencyTrackingMapLoaderTest.java:102
↓ 3 callersMethodassertPropertyNotSet
(String key)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:99
↓ 3 callersMethodassertPrunability
(int partitionCountUsed)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SpecificPartitionsImapReaderPmsTest.java:295
↓ 3 callersMethodassertRecoversXid
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXACompatibilityTest.java:169
↓ 3 callersMethodassertRepeatedSerialisationGivesSameByteArrays
(SerializationService ss, Portable p)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:284
↓ 3 callersMethodassertReplicationSlotActive
()
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcListenBeforeExistsIntegrationTest.java:230
↓ 3 callersMethodassertRequiresPrepare
(int recordCount, boolean expected)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseTest.java:119
↓ 3 callersMethodassertResultEventually
(Function<Integer, Stream<? extends String>> transformFn, int numItems)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/AsyncTransformUsingServiceP_IntegrationTest.java:232
↓ 3 callersMethodassertResultMap
(Map<Integer, Object> resultMap)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:938
↓ 3 callersMethodassertResultValue
(String label, ValueSerializationCountingData expected, ValueSerializationCountingData actual)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheSerializationCountTest.java:267
↓ 3 callersMethodassertRolledBack
(TransactionImpl tx)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseIT.java:77
↓ 3 callersMethodassertSafeEventually
(Collection<HazelcastInstance> instances)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionServiceSafetyCheckTest.java:271
↓ 3 callersMethodassertSecondary
(Addresses addresses, Address... expected)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProviderTest.java:120
↓ 3 callersMethodassertSequenceNumbersEqual
(Map<Integer, Long> source, Map<Integer, Long> destination)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/invalidation/MemberMapInvalidationMetaDataMigrationTest.java:314
↓ 3 callersMethodassertSnapshotMBeans
(Job job, String vertex, long expectedSnapshotKeys, boolean snapshotBytesExists)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobSnapshotMetricsTest.java:111
↓ 3 callersMethodassertSplitBrainMessagesCount
(final int clusterSize, final HazelcastInstance[] instances, fi
hazelcast/src/test/java/com/hazelcast/cluster/SlowMulticastJoinTest.java:124
↓ 3 callersMethodassertSqlDatesEqual
(java.sql.Date firstDate, java.sql.Date secondDate)
hazelcast/src/test/java/com/hazelcast/query/impl/DateHelperTest.java:96
↓ 3 callersMethodassertSqlTimesEqual
(Time firstTime, Time secondTime)
hazelcast/src/test/java/com/hazelcast/query/impl/DateHelperTest.java:247
↓ 3 callersMethodassertTaskExecutedItsLogic
()
hazelcast/src/test/java/com/hazelcast/executor/CompletableFutureTest.java:305
↓ 3 callersMethodassertThatDeserializedFunctionCreates
(Object deserialized, Class<?> expectedType)
hazelcast/src/test/java/com/hazelcast/jet/json/impl/JsonUtilImplTest.java:181
↓ 3 callersMethodassertThatNoCacheEvictionHappened
(ICache cache)
hazelcast/src/test/java/com/hazelcast/cache/CacheTestSupport.java:150
↓ 3 callersMethodassertThrowsJetException
(Job job, String messageFragment)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisFailureTest.java:268
↓ 3 callersMethodassertThrowsNPE
(ConsumerEx<ClientService> method)
hazelcast/src/test/java/com/hazelcast/client/AbstractClientServiceNullTest.java:37
↓ 3 callersMethodassertTimestampsEqual
(Timestamp firstTimestamp, Timestamp secondTimestamp)
hazelcast/src/test/java/com/hazelcast/query/impl/DateHelperTest.java:178
↓ 3 callersMethodassertToKey
(String key, Object object)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/OverloadedConnectionsPluginTest.java:122
↓ 3 callersMethodassertTopicEventually
(String name, String sql, Map<PersonId, Person> expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlPojoTest.java:286
↓ 3 callersMethodassertTrackingFileContents
(String pattern, Consumer<String> contentAssertion)
hazelcast/src/test/java/com/hazelcast/instance/InstanceTrackingInfoTest.java:121
↓ 3 callersMethodassertTrueKV
(boolean actual, long key, long value)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/Long2LongMapHsaTest.java:455
↓ 3 callersMethodassertTwoStageGlobalAggregation
(int i)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/RebalanceBatchStageTest.java:678
↓ 3 callersMethodassertTxLogState
(UUID txId, Transaction.State state)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionManagerServiceImplTest.java:106
↓ 3 callersMethodassertUuid
(String jsonResult, UUID expectedUuid)
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:229
↓ 3 callersMethodassertValid
(WaitSet waitSet, BlockedOperation operation, boolean valid)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/WaitSetTest.java:186
↓ 3 callersMethodassertValuesSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheMethodsWithPredicateTest.java:329
↓ 3 callersMethodassertValuesSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheMethodsWithPredicateTest.java:383
↓ 3 callersMethodassertVertexCount
(DAG dag, int expectedCount)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StreamStageTest.java:381
↓ 3 callersMethodassertWBStoreRunsOnPartitionThread
(State state)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/IMapOpStep.java:83
↓ 3 callersMethodassertWaitingOperationCountEventually
(int expectedOpsCount, HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1412
↓ 3 callersMethodassertionSink
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 callersMethodassignOutOfRangeNodeId
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/flakeidgen/impl/FlakeIdGenerator_NodeIdOverflowIntegrationTest.java:80
↓ 3 callersMethodassignOverflowedNodeId
(HazelcastInstance instance2)
hazelcast/src/test/java/com/hazelcast/client/flakeidgen/impl/FlakeIdGenerator_NodeIdOverflowIntegrationTest.java:104
↓ 3 callersMethodassumeHadoopSupportsIbmPlatform
()
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1595
↓ 3 callersMethodassumeThatMethodIsAvailable
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 callersMethodattachAll
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 callersMethodattachTo
(InternalIndex delegate)
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalQueryContextWithStats.java:78
↓ 3 callersMethodauthenticateAndAssert
(AuthenticationStatus status, byte serVersion, boolean useWrongClusterName, String clusterName)
hazelcast/src/test/java/com/hazelcast/client/AuthenticationInformationLeakTest.java:156
↓ 3 callersMethodavailabilityZoneEc2
()
hazelcast/src/main/java/com/hazelcast/aws/AwsMetadataApi.java:80
↓ 3 callersMethodavailabilityZoneEcs
()
hazelcast/src/main/java/com/hazelcast/aws/AwsMetadataApi.java:85
↓ 3 callersMethodavailableReplicaSyncPermits
Returns the number of available permits.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionReplicaManager.java:484
↓ 3 callersMethodavroFile
(Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/SqlAvroTest.java:323
↓ 3 callersMethodawaitAndForceShutdown
(Map<?, ? extends ExecutorService> executorServiceMap)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/impl/ExecutionServiceImpl.java:341
↓ 3 callersMethodawaitExecutorTermination
(String name, ExecutorService executor, ILogger logger)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientExecutionServiceImpl.java:90
↓ 3 callersMethodawaitFirstIteration
()
hazelcast/src/test/java/com/hazelcast/cache/CacheBasicAbstractTest.java:816
↓ 3 callersMethodawaitOnlyOneJobIsRunning
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/PartialJobMetricsCollectionTest.java:172
↓ 3 callersMethodawaitState
Await the result, throwing an error if something went wrong.
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientResult.java:317
↓ 3 callersMethodaxes
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 callersMethodbadPathException
(String path)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/extract/QueryPath.java:111
↓ 3 callersMethodbase64encodeUrlSafe
(String data)
hazelcast/src/main/java/com/hazelcast/gcp/GcpAuthenticator.java:131
↓ 3 callersMethodbatchDag
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:117
↓ 3 callersMethodbatchPipeline
()
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobLifecycleMetricsTest.java:307
↓ 3 callersMethodbeforeClusterStateChange
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 callersMethodbeforeRun
()
hazelcast/src/test/java/com/hazelcast/cluster/impl/DiscoverySPIJoinTest.java:95
↓ 3 callersMethodbegin
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 callersMethodbenchmark
(String label, Runnable run)
hazelcast/src/test/java/com/hazelcast/jet/benchmark/WordCountTest.java:212
↓ 3 callersMethodblacklist
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 callersMethodblockNewConnection
(Address address)
hazelcast/src/test/java/com/hazelcast/internal/server/FirewallingServer.java:195
↓ 3 callersMethodbouncingIntervalSeconds
(int bouncingIntervalSeconds)
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:543
↓ 3 callersMethodbroadcastConfigAsync
(IdentifiedDataSerializable config)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ClusterWideConfigurationService.java:256
↓ 3 callersMethodbucketCount
()
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:99
↓ 3 callersMethodbuild
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DeserializedSchemaBoundGenericRecordBuilder.java:44
↓ 3 callersMethodbuildBatch
( @Nonnull AggregateOperation<A, ? extends R> aggrOp, @Nonnull BiFunctionEx<? super K,
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/GrAggBuilder.java:95
↓ 3 callersMethodbuildHttpRequest
(String method)
hazelcast/src/main/java/com/hazelcast/spi/utils/RestClient.java:190
↓ 3 callersMethodbuildKubernetesApiUrlProvider
()
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesClient.java:162
↓ 3 callersMethodbuildNode
(YamlNode parent, String nodeName, Object sourceNode)
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlDomBuilder.java:61
↓ 3 callersMethodbuildQuery
(Predicate predicate)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/map/AbstractMapQueryMessageTask.java:185
↓ 3 callersMethodbuildReplicatedRecord
(K key, V value, long ttlMillis)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/AbstractReplicatedRecordStore.java:343
↓ 3 callersMethodbulkWrite
(List<? extends ClientNamespacedWriteModel> models)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/CloseableMongoClient.java:232
↓ 3 callersMethodbyteBufferToBytes
(ByteBuffer buffer)
hazelcast/src/test/java/com/hazelcast/instance/impl/TestUtil.java:269
↓ 3 callersMethodbytesToHex
Convert byte[] to hexadecimal string
hazelcast/src/main/java/com/hazelcast/internal/util/Sha256Util.java:83
↓ 3 callersMethodbytesTransceived
()
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioThread.java:153
↓ 3 callersMethodbytesWritten
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 callersMethodbytesWrittenSoFar
(BufferObjectDataOutput out)
hazelcast/src/main/java/com/hazelcast/internal/partition/ChunkSerDeHelper.java:177
↓ 3 callersMethodcalculateElapsed
(final long lastRepartitionNanos)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationTimer.java:43
← previousnext →13,501–13,600 of 147,315, ranked by callers