MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 4 callersMethodasReal
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:176
↓ 4 callersMethodasSerializable
(Configuration conf)
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/impl/SerializableConfiguration.java:56
↓ 4 callersMethodasSmallint
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:58
↓ 4 callersMethodasTime
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:93
↓ 4 callersMethodasTinyint
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:53
↓ 4 callersMethodasVarchar
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:108
↓ 4 callersMethodassertAllNormalMembers
(Cluster cluster)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:456
↓ 4 callersMethodassertAllNormalMembersEventually
(Cluster cluster)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:462
↓ 4 callersMethodassertAllPartitionContainersAreEmptyEventually
(final HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/map/MapDestroyTest.java:126
↓ 4 callersMethodassertAllPartitionContainersAreInitialized
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:240
↓ 4 callersMethodassertAtomicEventually
(final String message, final int expectedValue, final AtomicInte
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1155
↓ 4 callersMethodassertAwait
(int seconds)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreTest.java:1292
↓ 4 callersMethodassertAwsConfig
(AwsConfig aws)
hazelcast/src/test/java/com/hazelcast/config/AbstractConfigBuilderTest.java:695
↓ 4 callersMethodassertCloneEquals
(EndpointQualifier source)
hazelcast/src/test/java/com/hazelcast/test/starter/constructor/test/EndpointQualifierConstructorTest.java:67
↓ 4 callersMethodassertClosed
(MongoClient client)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnectionTest.java:166
↓ 4 callersMethodassertClusterSizeAlways
(final int expected, HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/internal/util/AbstractClockTest.java:167
↓ 4 callersMethodassertContainsAddedRecords
(IList<CustomerInfo> results)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:104
↓ 4 callersMethodassertContainsFileEventually
(final File dir)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsLogFileTest.java:197
↓ 4 callersMethodassertCorrectness
(List<Object> events)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SessionWindowPTest.java:168
↓ 4 callersMethodassertCounterValueEventually
(final long expectedValue, final PNCounter counter)
hazelcast/src/test/java/com/hazelcast/internal/crdt/pncounter/AbstractPNCounterBasicIntegrationTest.java:94
↓ 4 callersMethodassertCursorValid
()
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArrayBase.java:535
↓ 4 callersMethodassertDestinationPartitionMigrationEvent
(String msg, PartitionMigrationEvent event, MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:542
↓ 4 callersMethodassertDetectHeartbeatTimeoutEventually
(final Invocation invocation, final Invocation.HeartbeatTimeout yes)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/Invocation_DetectHeartbeatTimeoutTest.java:146
↓ 4 callersMethodassertEmittedCountEventually
(long expected)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamFilesPTest.java:346
↓ 4 callersMethodassertEmployeeMapSizeUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:251
↓ 4 callersMethodassertEmptyExecutionMetrics
(Job job, boolean saved)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_MiscTest.java:301
↓ 4 callersMethodassertEmptyJobMetrics
(Job job, boolean saved)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_MiscTest.java:306
↓ 4 callersMethodassertEmptyState
(SlidingWindowP p)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_twoStageSnapshotTest.java:205
↓ 4 callersMethodassertEqualCanonicalization
(Comparable<?>... values)
hazelcast/src/test/java/com/hazelcast/query/impl/NumbersTest.java:195
↓ 4 callersMethodassertEstimateValue
(final HazelcastInstance instance, final long value)
hazelcast/src/test/java/com/hazelcast/cardinality/CardinalityEstimatorBackupTest.java:83
↓ 4 callersMethodassertEventEventually
(final TestEventCollectingMapPartitionLostListener listener, fin
hazelcast/src/test/java/com/hazelcast/map/MapPartitionLostListenerTest.java:148
↓ 4 callersMethodassertFailsEventually
Asserts that the thread eventually completes with the expected error. @param cause the expected cause
hazelcast/src/test/java/com/hazelcast/test/TestThread.java:81
↓ 4 callersMethodassertFailureDetectorConfigEquals
(IcmpFailureDetectorConfig expected, IcmpFailureDetec
hazelcast/src/test/java/com/hazelcast/config/ConfigXmlGeneratorTest.java:1660
↓ 4 callersMethodassertInMemory
(HazelcastInstance[] instances, String mapName, String key, String expectedValue)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderSimpleTest.java:418
↓ 4 callersMethodassertInstanceOfByClassName
Asserts the instanceOf() by the classname only. <p> When running compatibility tests, Hazelcast classes are loaded by various classloaders, so instanc
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastStarterUtils.java:156
↓ 4 callersMethodassertInstanceSet
(final AtomicBoolean instanceSet)
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:146
↓ 4 callersMethodassertInvocationDurationBetween
(SlowOperationLog.Invocation invocation, int min, int max)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetectorAbstractTest.java:170
↓ 4 callersMethodassertIsCompatibleThrowsConfigMismatchException
(ConfigCheck c1, ConfigCheck c2)
hazelcast/src/test/java/com/hazelcast/cluster/ConfigCheckTest.java:141
↓ 4 callersMethodassertIsMultiResultAndGetResults
(Object result)
hazelcast/src/test/java/com/hazelcast/query/impl/DefaultValueCollectorTest.java:99
↓ 4 callersMethodassertJdbcRowsAnyOrderNoQuote
(String tableName, List<Class<?>> columnTypes, Row... rows)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:293
↓ 4 callersMethodassertJobIsAnalyzed
(String query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/AnalyzeStatementTest.java:395
↓ 4 callersMethodassertJobIsRunning
(JetService jetService, Path jarPath)
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/execute/JobExecuteClientSuccessTest.java:229
↓ 4 callersMethodassertLastMetricValue
(NodeEngine engine, int value, MetricDescriptor... metrics)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1450
↓ 4 callersMethodassertLastUpdateTimeUpdated
(Runnable runnable)
hazelcast/src/test/java/com/hazelcast/internal/monitor/impl/LocalRecordStoreStatsImplTest.java:210
↓ 4 callersMethodassertListOfMap
(List<Object> list)
hazelcast/src/test/java/com/hazelcast/jet/impl/util/JsonUtilTest.java:283
↓ 4 callersMethodassertListenerRegistration
()
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:141
↓ 4 callersMethodassertMXBeanRegistrationStatus
(boolean expectedStatus, String cacheName, boolean forStats)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheCreateUseDestroyTest.java:202
↓ 4 callersMethodassertMappingDestroyed
()
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapLoaderTest.java:822
↓ 4 callersMethodassertMaxBackupCountEventually
(final HazelcastInstance instance, final int maxBackupCount)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceLiteMemberTest.java:538
↓ 4 callersMethodassertMemberSet
(MemberMap map)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MemberMapTest.java:398
↓ 4 callersMethodassertMerged
(VectorClock from, VectorClock to, VectorClock expected)
hazelcast/src/test/java/com/hazelcast/cluster/impl/VectorClockTest.java:94
↓ 4 callersMethodassertMetricValueAtLeast
(String metricName, long minExpectedValue)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JmxMetricsChecker.java:93
↓ 4 callersMethodassertMoveInternal
(Path src, Path target, boolean withTimeout)
hazelcast/src/test/java/com/hazelcast/nio/IOUtilTest.java:947
↓ 4 callersMethodassertNew
(Set<Shard> shards, Object... expectedValues)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/impl/source/ShardTrackerTest.java:93
↓ 4 callersMethodassertNoMapContainersExist
(MapProxyImpl map)
hazelcast/src/test/java/com/hazelcast/map/impl/proxy/MapProxyImplTest.java:85
↓ 4 callersMethodassertNoMapContainersExist
(TransactionalMapProxy map)
hazelcast/src/test/java/com/hazelcast/map/impl/tx/TransactionalMapProxyTest.java:102
↓ 4 callersMethodassertNoPartitionsAssigned
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/DemoteDataMemberTest.java:475
↓ 4 callersMethodassertNoPreJoinCacheConfig
(CacheService cacheService)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheConfigPropagationTest.java:166
↓ 4 callersMethodassertNoRegisteredInterceptorExists
(IMap map)
hazelcast/src/test/java/com/hazelcast/client/map/SimpleClientMapInterceptorTest.java:142
↓ 4 callersMethodassertNoSnapshotExists
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:99
↓ 4 callersMethodassertNodeMapSizeUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:256
↓ 4 callersMethodassertNodeState
(HazelcastInstance[] instances, NodeState expectedState)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/BasicClusterStateTest.java:438
↓ 4 callersMethodassertNonMemberNetworkStatsAreZeroFromEMs
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AdvancedNetworkStatsIntegrationTest.java:156
↓ 4 callersMethodassertNotContains
(String string, String sequence)
hazelcast-build-utils/src/test/java/com/hazelcast/buildutils/PackageDefinitionTest.java:134
↓ 4 callersMethodassertNotEqualCanonicalization
(Comparable<?>... values)
hazelcast/src/test/java/com/hazelcast/query/impl/NumbersTest.java:204
↓ 4 callersMethodassertNotEqualsStringFormat
This method executes the normal assertNotEquals with expected and actual values. In addition, it formats the given string with those values to provide
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1374
↓ 4 callersMethodassertPartitionsIndexedMatchesPartitionsOwned
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/map/metrics/PartitionsIndexedTest.java:91
↓ 4 callersMethodassertPi
(Object value)
hazelcast/src/test/java/com/hazelcast/test/SplitBrainTestSupport.java:418
↓ 4 callersMethodassertPrepared
(TransactionImpl tx)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseIT.java:69
↓ 4 callersMethodassertPrimary
(Addresses addresses, Address... expected)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProviderTest.java:108
↓ 4 callersMethodassertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/cache/impl/LatencyTrackingCacheWriterTest.java:103
↓ 4 callersMethodassertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/LatencyTrackingRingbufferStoreTest.java:105
↓ 4 callersMethodassertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/map/impl/LatencyTrackingMapStoreTest.java:120
↓ 4 callersMethodassertQueryCacheSizeEventually
(final int expected, final IFunction<?, ?> function, fi
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheTest.java:321
↓ 4 callersMethodassertQueryForEmployeeMapUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:261
↓ 4 callersMethodassertQueryForNodeMapUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:267
↓ 4 callersMethodassertRangePredicate
(RangePredicate actual, String expectedAttribute, Comparable expectedFrom,
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/BasicBoundedRangePredicateTest.java:60
↓ 4 callersMethodassertRegistrationsSizeEventually
(final HazelcastInstance instance, final int expectedSize)
hazelcast/src/test/java/com/hazelcast/partition/PartitionLostListenerRegistrationTest.java:130
↓ 4 callersMethodassertReplacerWorks
(AbstractPbeReplacer replacer)
hazelcast/src/test/java/com/hazelcast/config/replacer/AbstractPbeReplacerTest.java:123
↓ 4 callersMethodassertReplicaVersionsAndServiceData
(String msg, Address address, int partitionId, int replicaIndex)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:496
↓ 4 callersMethodassertReplicatedMapsB
(Object key, Object expectedValue)
hazelcast/src/test/java/com/hazelcast/replicatedmap/merge/ReplicatedMapSplitBrainTest.java:381
↓ 4 callersMethodassertReplicatedMapsSizeB
(int expectedSize)
hazelcast/src/test/java/com/hazelcast/replicatedmap/merge/ReplicatedMapSplitBrainTest.java:400
↓ 4 callersMethodassertSchemasAvailable
(Collection<HazelcastInstance> instances, Class<?>... classes)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:318
↓ 4 callersMethodassertSchemasAvailableInEveryMember
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:231
↓ 4 callersMethodassertSetterThrows
(GenericRecordBuilder builder, String fieldName, int value, String errorMessage)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/GenericRecordTest.java:188
↓ 4 callersMethodassertSetterThrows
(GenericRecordBuilder builder, String fieldName, int value, String errorMessage)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/GenericRecordBuilderTest.java:213
↓ 4 callersMethodassertSingleDocument
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:230
↓ 4 callersMethodassertSizeAndLoadCount
(IMap<?, ?> map)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapLoaderFailoverTest.java:207
↓ 4 callersMethodassertSnapshotExists
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:92
↓ 4 callersMethodassertSourcePartitionMigrationEvent
(String msg, PartitionMigrationEvent event, MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:536
↓ 4 callersMethodassertSqlResultUnique
(String sql, int expectedCount, boolean stopEarly)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:958
↓ 4 callersMethodassertStatusNotRunningOrStarting
(JobStatus status)
hazelcast/src/test/java/com/hazelcast/jet/core/SplitBrainTest.java:320
↓ 4 callersMethodassertStillRunning
()
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioThreadAbstractTest.java:163
↓ 4 callersMethodassertTailEqualsEventually
(List<T> actual, T... expected)
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:303
↓ 4 callersMethodassertThatIncrementedAllItems
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StageExtensionTest.java:122
↓ 4 callersMethodassertThatOperationWasDiscarded
operation was quietly removed
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerMigrationTest.java:252
↓ 4 callersMethodassertTopicEventually
(String name, String sql, Map<String, String> expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlJsonTest.java:285
↓ 4 callersMethodassertTrueAllTheTime
(AssertTask task, long durationSeconds)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/TpcTestSupport.java:137
↓ 4 callersMethodassertTrueInProcessor
If expression is false, given message will be added to set of errors and will cause {@link TestProcessors#assertNoErrorsInProcessors()} to fail.
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:133
↓ 4 callersMethodassertTrue_withNullEntry
(Predicate p)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/PredicatesTest.java:401
← previousnext →11,501–11,600 of 147,315, ranked by callers