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
↓ 4 callers
Method
asReal
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:176
↓ 4 callers
Method
asSerializable
(Configuration conf)
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/impl/SerializableConfiguration.java:56
↓ 4 callers
Method
asSmallint
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:58
↓ 4 callers
Method
asTime
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:93
↓ 4 callers
Method
asTinyint
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:53
↓ 4 callers
Method
asVarchar
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/ObjectConverter.java:108
↓ 4 callers
Method
assertAllNormalMembers
(Cluster cluster)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:456
↓ 4 callers
Method
assertAllNormalMembersEventually
(Cluster cluster)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/PromoteLiteMemberTest.java:462
↓ 4 callers
Method
assertAllPartitionContainersAreEmptyEventually
(final HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/map/MapDestroyTest.java:126
↓ 4 callers
Method
assertAllPartitionContainersAreInitialized
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:240
↓ 4 callers
Method
assertAtomicEventually
(final String message, final int expectedValue, final AtomicInte
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1155
↓ 4 callers
Method
assertAwait
(int seconds)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreTest.java:1292
↓ 4 callers
Method
assertAwsConfig
(AwsConfig aws)
hazelcast/src/test/java/com/hazelcast/config/AbstractConfigBuilderTest.java:695
↓ 4 callers
Method
assertCloneEquals
(EndpointQualifier source)
hazelcast/src/test/java/com/hazelcast/test/starter/constructor/test/EndpointQualifierConstructorTest.java:67
↓ 4 callers
Method
assertClosed
(MongoClient client)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/dataconnection/MongoDataConnectionTest.java:166
↓ 4 callers
Method
assertClusterSizeAlways
(final int expected, HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/internal/util/AbstractClockTest.java:167
↓ 4 callers
Method
assertContainsAddedRecords
(IList<CustomerInfo> results)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:104
↓ 4 callers
Method
assertContainsFileEventually
(final File dir)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsLogFileTest.java:197
↓ 4 callers
Method
assertCorrectness
(List<Object> events)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SessionWindowPTest.java:168
↓ 4 callers
Method
assertCounterValueEventually
(final long expectedValue, final PNCounter counter)
hazelcast/src/test/java/com/hazelcast/internal/crdt/pncounter/AbstractPNCounterBasicIntegrationTest.java:94
↓ 4 callers
Method
assertCursorValid
()
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArrayBase.java:535
↓ 4 callers
Method
assertDestinationPartitionMigrationEvent
(String msg, PartitionMigrationEvent event, MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:542
↓ 4 callers
Method
assertDetectHeartbeatTimeoutEventually
(final Invocation invocation, final Invocation.HeartbeatTimeout yes)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/Invocation_DetectHeartbeatTimeoutTest.java:146
↓ 4 callers
Method
assertEmittedCountEventually
(long expected)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamFilesPTest.java:346
↓ 4 callers
Method
assertEmployeeMapSizeUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:251
↓ 4 callers
Method
assertEmptyExecutionMetrics
(Job job, boolean saved)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_MiscTest.java:301
↓ 4 callers
Method
assertEmptyJobMetrics
(Job job, boolean saved)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_MiscTest.java:306
↓ 4 callers
Method
assertEmptyState
(SlidingWindowP p)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_twoStageSnapshotTest.java:205
↓ 4 callers
Method
assertEqualCanonicalization
(Comparable<?>... values)
hazelcast/src/test/java/com/hazelcast/query/impl/NumbersTest.java:195
↓ 4 callers
Method
assertEstimateValue
(final HazelcastInstance instance, final long value)
hazelcast/src/test/java/com/hazelcast/cardinality/CardinalityEstimatorBackupTest.java:83
↓ 4 callers
Method
assertEventEventually
(final TestEventCollectingMapPartitionLostListener listener, fin
hazelcast/src/test/java/com/hazelcast/map/MapPartitionLostListenerTest.java:148
↓ 4 callers
Method
assertFailsEventually
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 callers
Method
assertFailureDetectorConfigEquals
(IcmpFailureDetectorConfig expected, IcmpFailureDetec
hazelcast/src/test/java/com/hazelcast/config/ConfigXmlGeneratorTest.java:1660
↓ 4 callers
Method
assertInMemory
(HazelcastInstance[] instances, String mapName, String key, String expectedValue)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderSimpleTest.java:418
↓ 4 callers
Method
assertInstanceOfByClassName
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 callers
Method
assertInstanceSet
(final AtomicBoolean instanceSet)
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:146
↓ 4 callers
Method
assertInvocationDurationBetween
(SlowOperationLog.Invocation invocation, int min, int max)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetectorAbstractTest.java:170
↓ 4 callers
Method
assertIsCompatibleThrowsConfigMismatchException
(ConfigCheck c1, ConfigCheck c2)
hazelcast/src/test/java/com/hazelcast/cluster/ConfigCheckTest.java:141
↓ 4 callers
Method
assertIsMultiResultAndGetResults
(Object result)
hazelcast/src/test/java/com/hazelcast/query/impl/DefaultValueCollectorTest.java:99
↓ 4 callers
Method
assertJdbcRowsAnyOrderNoQuote
(String tableName, List<Class<?>> columnTypes, Row... rows)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:293
↓ 4 callers
Method
assertJobIsAnalyzed
(String query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/AnalyzeStatementTest.java:395
↓ 4 callers
Method
assertJobIsRunning
(JetService jetService, Path jarPath)
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/execute/JobExecuteClientSuccessTest.java:229
↓ 4 callers
Method
assertLastMetricValue
(NodeEngine engine, int value, MetricDescriptor... metrics)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1450
↓ 4 callers
Method
assertLastUpdateTimeUpdated
(Runnable runnable)
hazelcast/src/test/java/com/hazelcast/internal/monitor/impl/LocalRecordStoreStatsImplTest.java:210
↓ 4 callers
Method
assertListOfMap
(List<Object> list)
hazelcast/src/test/java/com/hazelcast/jet/impl/util/JsonUtilTest.java:283
↓ 4 callers
Method
assertListenerRegistration
()
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:141
↓ 4 callers
Method
assertMXBeanRegistrationStatus
(boolean expectedStatus, String cacheName, boolean forStats)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheCreateUseDestroyTest.java:202
↓ 4 callers
Method
assertMappingDestroyed
()
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapLoaderTest.java:822
↓ 4 callers
Method
assertMaxBackupCountEventually
(final HazelcastInstance instance, final int maxBackupCount)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceLiteMemberTest.java:538
↓ 4 callers
Method
assertMemberSet
(MemberMap map)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MemberMapTest.java:398
↓ 4 callers
Method
assertMerged
(VectorClock from, VectorClock to, VectorClock expected)
hazelcast/src/test/java/com/hazelcast/cluster/impl/VectorClockTest.java:94
↓ 4 callers
Method
assertMetricValueAtLeast
(String metricName, long minExpectedValue)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JmxMetricsChecker.java:93
↓ 4 callers
Method
assertMoveInternal
(Path src, Path target, boolean withTimeout)
hazelcast/src/test/java/com/hazelcast/nio/IOUtilTest.java:947
↓ 4 callers
Method
assertNew
(Set<Shard> shards, Object... expectedValues)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/impl/source/ShardTrackerTest.java:93
↓ 4 callers
Method
assertNoMapContainersExist
(MapProxyImpl map)
hazelcast/src/test/java/com/hazelcast/map/impl/proxy/MapProxyImplTest.java:85
↓ 4 callers
Method
assertNoMapContainersExist
(TransactionalMapProxy map)
hazelcast/src/test/java/com/hazelcast/map/impl/tx/TransactionalMapProxyTest.java:102
↓ 4 callers
Method
assertNoPartitionsAssigned
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/DemoteDataMemberTest.java:475
↓ 4 callers
Method
assertNoPreJoinCacheConfig
(CacheService cacheService)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheConfigPropagationTest.java:166
↓ 4 callers
Method
assertNoRegisteredInterceptorExists
(IMap map)
hazelcast/src/test/java/com/hazelcast/client/map/SimpleClientMapInterceptorTest.java:142
↓ 4 callers
Method
assertNoSnapshotExists
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:99
↓ 4 callers
Method
assertNodeMapSizeUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:256
↓ 4 callers
Method
assertNodeState
(HazelcastInstance[] instances, NodeState expectedState)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/BasicClusterStateTest.java:438
↓ 4 callers
Method
assertNonMemberNetworkStatsAreZeroFromEMs
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AdvancedNetworkStatsIntegrationTest.java:156
↓ 4 callers
Method
assertNotContains
(String string, String sequence)
hazelcast-build-utils/src/test/java/com/hazelcast/buildutils/PackageDefinitionTest.java:134
↓ 4 callers
Method
assertNotEqualCanonicalization
(Comparable<?>... values)
hazelcast/src/test/java/com/hazelcast/query/impl/NumbersTest.java:204
↓ 4 callers
Method
assertNotEqualsStringFormat
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 callers
Method
assertPartitionsIndexedMatchesPartitionsOwned
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/map/metrics/PartitionsIndexedTest.java:91
↓ 4 callers
Method
assertPi
(Object value)
hazelcast/src/test/java/com/hazelcast/test/SplitBrainTestSupport.java:418
↓ 4 callers
Method
assertPrepared
(TransactionImpl tx)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionImpl_TwoPhaseIT.java:69
↓ 4 callers
Method
assertPrimary
(Addresses addresses, Address... expected)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/DefaultAddressProviderTest.java:108
↓ 4 callers
Method
assertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/cache/impl/LatencyTrackingCacheWriterTest.java:103
↓ 4 callers
Method
assertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/LatencyTrackingRingbufferStoreTest.java:105
↓ 4 callers
Method
assertProbeCalledOnce
(String methodName)
hazelcast/src/test/java/com/hazelcast/map/impl/LatencyTrackingMapStoreTest.java:120
↓ 4 callers
Method
assertQueryCacheSizeEventually
(final int expected, final IFunction<?, ?> function, fi
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/QueryCacheTest.java:321
↓ 4 callers
Method
assertQueryForEmployeeMapUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:261
↓ 4 callers
Method
assertQueryForNodeMapUsing
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:267
↓ 4 callers
Method
assertRangePredicate
(RangePredicate actual, String expectedAttribute, Comparable expectedFrom,
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/BasicBoundedRangePredicateTest.java:60
↓ 4 callers
Method
assertRegistrationsSizeEventually
(final HazelcastInstance instance, final int expectedSize)
hazelcast/src/test/java/com/hazelcast/partition/PartitionLostListenerRegistrationTest.java:130
↓ 4 callers
Method
assertReplacerWorks
(AbstractPbeReplacer replacer)
hazelcast/src/test/java/com/hazelcast/config/replacer/AbstractPbeReplacerTest.java:123
↓ 4 callers
Method
assertReplicaVersionsAndServiceData
(String msg, Address address, int partitionId, int replicaIndex)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:496
↓ 4 callers
Method
assertReplicatedMapsB
(Object key, Object expectedValue)
hazelcast/src/test/java/com/hazelcast/replicatedmap/merge/ReplicatedMapSplitBrainTest.java:381
↓ 4 callers
Method
assertReplicatedMapsSizeB
(int expectedSize)
hazelcast/src/test/java/com/hazelcast/replicatedmap/merge/ReplicatedMapSplitBrainTest.java:400
↓ 4 callers
Method
assertSchemasAvailable
(Collection<HazelcastInstance> instances, Class<?>... classes)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:318
↓ 4 callers
Method
assertSchemasAvailableInEveryMember
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:231
↓ 4 callers
Method
assertSetterThrows
(GenericRecordBuilder builder, String fieldName, int value, String errorMessage)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/GenericRecordTest.java:188
↓ 4 callers
Method
assertSetterThrows
(GenericRecordBuilder builder, String fieldName, int value, String errorMessage)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/GenericRecordBuilderTest.java:213
↓ 4 callers
Method
assertSingleDocument
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:230
↓ 4 callers
Method
assertSizeAndLoadCount
(IMap<?, ?> map)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapLoaderFailoverTest.java:207
↓ 4 callers
Method
assertSnapshotExists
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:92
↓ 4 callers
Method
assertSourcePartitionMigrationEvent
(String msg, PartitionMigrationEvent event, MigrationInfo migration)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:536
↓ 4 callers
Method
assertSqlResultUnique
(String sql, int expectedCount, boolean stopEarly)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:958
↓ 4 callers
Method
assertStatusNotRunningOrStarting
(JobStatus status)
hazelcast/src/test/java/com/hazelcast/jet/core/SplitBrainTest.java:320
↓ 4 callers
Method
assertStillRunning
()
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioThreadAbstractTest.java:163
↓ 4 callers
Method
assertTailEqualsEventually
(List<T> actual, T... expected)
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:303
↓ 4 callers
Method
assertThatIncrementedAllItems
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/StageExtensionTest.java:122
↓ 4 callers
Method
assertThatOperationWasDiscarded
operation was quietly removed
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerMigrationTest.java:252
↓ 4 callers
Method
assertTopicEventually
(String name, String sql, Map<String, String> expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlJsonTest.java:285
↓ 4 callers
Method
assertTrueAllTheTime
(AssertTask task, long durationSeconds)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/TpcTestSupport.java:137
↓ 4 callers
Method
assertTrueInProcessor
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 callers
Method
assertTrue_withNullEntry
(Predicate p)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/PredicatesTest.java:401
← previous
next →
11,501–11,600 of 147,315, ranked by callers