MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

⨍ Functions 147,315◇ Types & classes 15,944
↓ 2 callersMethodassertMapPartitionLostListener
(String listenerName, MapConfig mapConfig)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:1773
↓ 2 callersMethodassertMapPutCountMetric
(HazelcastInstance instance, int expected)
hazelcast/src/test/java/com/hazelcast/map/LocalMapStatsProviderTest.java:106
↓ 2 callersMethodassertMaxAggregators
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:181
↓ 2 callersMethodassertMembershipEvent
(EventObject e, int type, Member changedMember, Member... expectedMembers)
hazelcast/src/test/java/com/hazelcast/cluster/ClusterMembershipListenerTest.java:254
↓ 2 callersMethodassertMembershipRemovedEvent
(EventObject e, Member addedMember, Member... expectedMembers)
hazelcast/src/test/java/com/hazelcast/cluster/ClusterMembershipListenerTest.java:250
↓ 2 callersMethodassertMergePolicyCorrectlyInitialised
(String mergePolicyName, Class<? extends SplitBrainMerg
hazelcast/src/test/java/com/hazelcast/spi/merge/SplitBrainMergePolicyProviderTest.java:82
↓ 2 callersMethodassertMessageEquals
(ClientMessage expected, ClientMessage actual)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/util/ClientMessageSplitAndBuildTest.java:195
↓ 2 callersMethodassertMessages
(Map<String, List<String>> expected, boolean checkOrder, boolean deduplicate)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/AbstractKinesisTest.java:159
↓ 2 callersMethodassertMetadataCreatedEventually
(final String mapName)
hazelcast/src/test/java/com/hazelcast/json/internal/JsonMetadataCreationTest.java:329
↓ 2 callersMethodassertMigrationEvents
(TestAbstractMigrationAwareService service, Address thisAddress)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionCorrectnessTestSupport.java:347
↓ 2 callersMethodassertMinAggregators
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:161
↓ 2 callersMethodassertMultiMapBackups
(String multiMapName, int backupCount, int asyncBackupCount, int keyCou
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapBackupTest.java:117
↓ 2 callersMethodassertMultiMaps
(MultiMap<Object, Object> multiMap1, MultiMap<Object, Object> multiMap2,
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapSplitBrainTest.java:436
↓ 2 callersMethodassertMultiMapsSize
(MultiMap<?, ?> multiMap1, MultiMap<?, ?> multiMap2, Map<?, ? exte
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapSplitBrainTest.java:472
↓ 2 callersMethodassertNamespaceConfig
(String yamlTestString)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:5445
↓ 2 callersMethodassertNearCacheContent
(NearCacheTestContext<?, ?, ?, ?> context, int keyCount, KeyType keyType)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:491
↓ 2 callersMethodassertNearCacheExpiration
(final IMap<Integer, Integer> map, final int size)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTestSupport.java:94
↓ 2 callersMethodassertNearCacheInvalidationsBetween
Asserts the number of Near Cache invalidations. @param context the given {@link NearCacheTestContext} to retrieve the {@link NearCacheStats}
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:372
↓ 2 callersMethodassertNearCacheManager
(NearCacheTestContext<Integer, Integer, ?, ?> context, int expected)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheLeakTest.java:102
↓ 2 callersMethodassertNearCachePreloadDoneEventually
(final NearCacheTestContext clientContext)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:476
↓ 2 callersMethodassertNearCacheRecord
Asserts the state and class of a {@link NearCacheRecord} and its value. @param cacheRecord the {@link NearCacheRecord} @param key the k
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:314
↓ 2 callersMethodassertNearCacheStats
(NearCacheStatsImpl stats, long expectedPersistenceCount, long expectedDuration,
hazelcast/src/test/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImplTest.java:147
↓ 2 callersMethodassertNoAsyncTrace
(Throwable result)
hazelcast/src/test/java/com/hazelcast/internal/util/ExceptionUtilTest.java:151
↓ 2 callersMethodassertNoDocuments
(String index)
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:245
↓ 2 callersMethodassertNoDuplicate
(int partitionId, PartitionReplica[] oldReplicas, PartitionReplica[] newReplicas)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationPlanner.java:306
↓ 2 callersMethodassertNoFurtherInvalidation
()
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheInvalidationTest.java:517
↓ 2 callersMethodassertNoFurtherInvalidationThan
(final int expectedInvalidationCount)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheInvalidationTest.java:521
↓ 2 callersMethodassertNoLeakingData
(TestAbstractMigrationAwareService<N> service, InternalPartition[] partitions,
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionCorrectnessTestSupport.java:276
↓ 2 callersMethodassertNoMissingData
(TestAbstractMigrationAwareService<N> service, InternalPartition[] partitions,
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionCorrectnessTestSupport.java:287
↓ 2 callersMethodassertNoPartitionsAssigned
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:446
↓ 2 callersMethodassertNoRegisteredInterceptorExists
(IMap<Object, Object> map)
hazelcast/src/test/java/com/hazelcast/map/InterceptorTest.java:112
↓ 2 callersMethodassertNoRunningInstances
()
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:802
↓ 2 callersMethodassertNoStaleDataExistInNearCache
(IMap<Integer, Integer> map)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/MapNearCacheStalenessTest.java:130
↓ 2 callersMethodassertNoState
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/misc/SqlClientCursorCleanupTest.java:116
↓ 2 callersMethodassertNodesShutDownEventually
(Node[] nodes)
hazelcast/src/test/java/com/hazelcast/cluster/ClusterShutdownTest.java:165
↓ 2 callersMethodassertNonEmptyPendingInvocationAndWaitSet
(HazelcastInstance server)
hazelcast/src/test/java/com/hazelcast/client/ClientDisconnectTest.java:193
↓ 2 callersMethodassertNotClosed
(MongoClient client)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnectionTest.java:163
↓ 2 callersMethodassertNotContains
(MemberMap map, Address address)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MemberMapTest.java:415
↓ 2 callersMethodassertNothingProcessed
()
hazelcast/src/test/java/com/hazelcast/jet/job/BatchJobInitialSnapshotTest.java:152
↓ 2 callersMethodassertObserverStopsReceivingValues
(TestObserver observer)
hazelcast/src/test/java/com/hazelcast/jet/core/ObservableShutdownTest.java:104
↓ 2 callersMethodassertOneOfExceptionsInCauses
(Throwable caught, Throwable... expected)
hazelcast/src/test/java/com/hazelcast/jet/core/ExecutionLifecycleTest.java:1220
↓ 2 callersMethodassertOrdered
Asserts that the previous stage emitted the exact sequence of expected items and nothing else. If the assertion fails, the job will fail with an {@lin
hazelcast/src/main/java/com/hazelcast/jet/pipeline/test/AssertionSinks.java:59
↓ 2 callersMethodassertOutput
Runs the test with the specified custom assertion. <p> The consumer takes a list of collected output and the current test mode which can be used in th
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:426
↓ 2 callersMethodassertPartitionUUIDsEqual
(Map<Integer, UUID> source, Map<Integer, UUID> destination)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/invalidation/MemberMapInvalidationMetaDataMigrationTest.java:327
↓ 2 callersMethodassertPartitionsAssigned
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:433
↓ 2 callersMethodassertPartitionsAssignedEventually
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:429
↓ 2 callersMethodassertPluginsWhenDiagnosticsDisabled
(Diagnostics diagnostics)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsTest.java:222
↓ 2 callersMethodassertPredicate
(Predicate expected, AndPredicate original, Predicate actual)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/VisitorTestSupport.java:103
↓ 2 callersMethodassertPredicate
(Predicate expected, Predicate actual)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeEqualPredicateTest.java:118
↓ 2 callersMethodassertPredicate
(Predicate expected, Predicate actual)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeRangePredicateTest.java:263
↓ 2 callersMethodassertPredicateResultCorrect
(final IMap<Integer, SampleIndexableObject> map, final Predicate predicate)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapLoaderTest.java:700
↓ 2 callersMethodassertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/cache/impl/LatencyTrackingCacheLoaderTest.java:95
↓ 2 callersMethodassertPromotionInvocationStarted
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:415
↓ 2 callersMethodassertPropertiesEquals
alternative implementation of {@link org.assertj.core.api.AbstractMapAssert#isEqualTo(Object)} that queries via {@link Properties#stringPropertyNames(
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:904
↓ 2 callersMethodassertQueryCacheSizeEventually
(final int expected, final IFunction<?, ?> function, final QueryCache queryCache)
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheTest.java:261
↓ 2 callersMethodassertQueryCacheSizeEventually
(final int expected, final QueryCache cache)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheConfigTest.java:82
↓ 2 callersMethodassertRandomMetricValueAtLeast
(String metricName, long minExpectedValue)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetricsChecker.java:77
↓ 2 callersMethodassertRangeLoaded
(IMap map, int rangeStart, int rangeEnd)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/LoadAllTest.java:231
↓ 2 callersMethodassertRangePredicate
(RangePredicate expected, Predicate actual)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/VisitorTestSupport.java:144
↓ 2 callersMethodassertReadAsNullable
(GenericRecord record)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactNullablePrimitiveInteroperabilityTest.java:177
↓ 2 callersMethodassertReadAsPrimitive
(GenericRecord record)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactNullablePrimitiveInteroperabilityTest.java:225
↓ 2 callersMethodassertReadFully
(DataInputNavigableJsonAdapter.UTF8Reader reader, byte[] sample)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/DataInputNavigableJsonAdapterTest.java:159
↓ 2 callersMethodassertReadMixed
(byte[] sample, boolean singleReadFirst)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/DataInputNavigableJsonAdapterTest.java:183
↓ 2 callersMethodassertReadNullAsPrimitiveThrowsException
(GenericRecord record)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactNullablePrimitiveInteroperabilityTest.java:316
↓ 2 callersMethodassertRecommendationContent
(LogEvent logEvent, boolean emojiExpected)
hazelcast/src/test/java/com/hazelcast/instance/impl/NodeSecurityBannerTest.java:113
↓ 2 callersMethodassertRecord
(ReplicatedRecord<String, String> record, long startTime)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapHitsAndLastAccessTimeTest.java:87
↓ 2 callersMethodassertRecoversNothing
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXACompatibilityTest.java:240
↓ 2 callersMethodassertRecoversXid
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXACompatibilityTest.java:235
↓ 2 callersMethodassertReflectiveCompactSerializationReadOutcome
(Callable<Object> block)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/AbstractReflectiveSerializationRestrictionTest.java:138
↓ 2 callersMethodassertReflectiveCompactSerializationWriteOutcome
(ThrowableAssert.ThrowingCallable block)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/AbstractReflectiveSerializationRestrictionTest.java:153
↓ 2 callersMethodassertRegistrationSize
(int size)
hazelcast/src/test/java/com/hazelcast/topic/TopicDestroyTest.java:68
↓ 2 callersMethodassertRepairingTask
(NearCacheTestContext<Integer, Integer, ?, ?> context, int expected)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheLeakTest.java:107
↓ 2 callersMethodassertReplicaVersionsAndBackupValues
(int actualBackupCount, TestAbstractMigrationAwareService<N> service,
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionCorrectnessTestSupport.java:299
↓ 2 callersMethodassertReplicatedMaps
(final ReplicatedMap<Object, Object> replicatedMap1, final Replic
hazelcast/src/test/java/com/hazelcast/replicatedmap/merge/ReplicatedMapSplitBrainTest.java:385
↓ 2 callersMethodassertReplicatedMapsSize
(final ReplicatedMap<Object, Object> replicatedMap1, final Re
hazelcast/src/test/java/com/hazelcast/replicatedmap/merge/ReplicatedMapSplitBrainTest.java:404
↓ 2 callersMethodassertRequiredPartitions
(Set<Integer> expectedPartitions, Set<Integer> actualPartitions)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlPartitionPruningE2ETest.java:424
↓ 2 callersMethodassertResourcePresence
(boolean isResourceExpected, String resourcePath)
hazelcast/src/test/java/com/hazelcast/it/CheckNoticeFileIT.java:41
↓ 2 callersMethodassertResult
(Function<Integer, Stream<? extends String>> transformFn, int numItems)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/AsyncTransformUsingServiceBatchP_IntegrationTest.java:197
↓ 2 callersMethodassertResultMap
(String label, ValueSerializationCountingData expected, Map<KeySerializationC
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheSerializationCountTest.java:280
↓ 2 callersMethodassertRowsAnyOrder
(String sql, List<Row> expectedRows, Thread mutator, Function<Row, Integer
hazelcast-sql/src/test/java/com/hazelcast/jet/sql_slow/MapScanMigrationStressTest.java:210
↓ 2 callersMethodassertSafe
(Collection<HazelcastInstance> instances)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionServiceSafetyCheckTest.java:264
↓ 2 callersMethodassertSecondaryEmpty
(Addresses addresses)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProviderTest.java:112
↓ 2 callersMethodassertSingleStageAggregation
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/RebalanceStreamStageTest.java:212
↓ 2 callersMethodassertSnapshotExists
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/job/StreamMapJournalReliabilityTest.java:174
↓ 2 callersMethodassertSnapshotNotCommitted
()
hazelcast/src/test/java/com/hazelcast/jet/core/IndeterminateSnapshotTest.java:193
↓ 2 callersMethodassertSplitBrainProtectionIsAbsentEventually
(final HazelcastInstance instance, final String splitBrainProtectionId)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/PartitionedCluster.java:159
↓ 2 callersMethodassertSqlExceptionWithShutdown
(HazelcastInstance instance, SqlStatement query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlErrorAbstractTest.java:158
↓ 2 callersMethodassertState
(PNCounter driver)
hazelcast/src/test/java/com/hazelcast/internal/crdt/pncounter/AbstractPNCounterConsistencyLostTest.java:69
↓ 2 callersMethodassertStates
(LifecycleState... states)
hazelcast/src/test/java/com/hazelcast/cluster/SplitMergeTest.java:207
↓ 2 callersMethodassertStatistics
(int expectedHits)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheCreateUseDestroyTest.java:197
↓ 2 callersMethodassertStatsObjectCreated
()
hazelcast/src/test/java/com/hazelcast/map/impl/MapStatisticsAwareServiceTest.java:68
↓ 2 callersMethodassertStoreLatencyPlugin
(boolean status)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsNonDynamicPluginTests.java:81
↓ 2 callersMethodassertSumAggregators
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:201
↓ 2 callersMethodassertSumAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:384
↓ 2 callersMethodassertTerminates
Asserts that the thread eventually completes, no matter if there is an error or not.
hazelcast/src/test/java/com/hazelcast/test/TestThread.java:64
↓ 2 callersMethodassertTestExceptionThrown
(AtomicReference<?>... refs)
hazelcast/src/test/java/com/hazelcast/executor/CompletableFutureTest.java:255
↓ 2 callersMethodassertThatMigrationIsDoneAndReplicasAreIntact
(List<HazelcastInstance> list)
hazelcast/src/test/java/com/hazelcast/map/MigrationTest.java:119
↓ 2 callersMethodassertThatOperationWasExecuted
(WaitSetTest.BlockedOperation op)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerMigrationTest.java:259
↓ 2 callersMethodassertThatOperationWasInvalidated
PartitionMigratingException was sent
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerMigrationTest.java:243
↓ 2 callersMethodassertThatQueueIsFull
(JobMetrics metrics, String vertexName)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_BackpressureTest.java:89
← previousnext →16,501–16,600 of 147,315, ranked by callers