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
↓ 2 callers
Method
asVarchar
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/AbstractStringConverter.java:171
↓ 2 callers
Method
asYamlType
(Node node, Class<T> type)
hazelcast/src/main/java/com/hazelcast/internal/config/yaml/W3cDomUtil.java:91
↓ 2 callers
Method
assertAggregatedMetricValue
(String metricName, long expectedValue, Function<List<Measurement
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetricsChecker.java:82
↓ 2 callers
Method
assertAggregatedMetricValueAtLeast
(String metricName, long minExpectedValue, Function<List<M
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetricsChecker.java:98
↓ 2 callers
Method
assertAllNetworkStatsAreZeroFromEMs
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AdvancedNetworkStatsIntegrationTest.java:150
↓ 2 callers
Method
assertAllNetworkStatsNotRegisteredAsMetrics
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AdvancedNetworkStatsIntegrationTest.java:207
↓ 2 callers
Method
assertAllTtlSchedulersEmpty
(ReplicatedMap map)
hazelcast/src/test/java/com/hazelcast/client/replicatedmap/ClientReplicatedMapTest.java:1013
↓ 2 callers
Method
assertAllocated
(long address)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/HeapMemoryManager.java:175
↓ 2 callers
Method
assertAllowedException
(Collection<? extends Future<?>> futures, Class<?> allowedException)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/executor/ExecutorSplitBrainProtectionWriteTest.java:556
↓ 2 callers
Method
assertArrayHashcodes
Asserts {@code double[][]} arrays by an array of hash codes per sub-array. <p> The method {@link Arrays#hashCode(Object[])} is not constant for {@code
hazelcast/src/test/java/com/hazelcast/cardinality/impl/hyperloglog/impl/DenseHyperLogLogConstantsTest.java:93
↓ 2 callers
Method
assertAsyncJobIsAnalyzed
Same as {@link #assertJobIsAnalyzed(String)} but does not wait for {@link com.hazelcast.sql.SqlService#execute} to finish and is better suited for tes
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/AnalyzeStatementTest.java:407
↓ 2 callers
Method
assertAttributeEqual
(String expectedName, String expectedExtractor, AttributeConfig attributeConfig)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:2886
↓ 2 callers
Method
assertAttributeEqual
(String expectedName, String expectedExtractor, AttributeConfig attributeConfig)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:2797
↓ 2 callers
Method
assertAverageAggregators
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:225
↓ 2 callers
Method
assertAverageAggregatorsAnyCornerCase
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:408
↓ 2 callers
Method
assertAwait
(int seconds)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferStoreTest.java:433
↓ 2 callers
Method
assertAwsConfig
(AwsConfig aws)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/TestFullApplicationContext.java:892
↓ 2 callers
Method
assertAzureConfig
(AzureConfig azure)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/TestFullApplicationContext.java:909
↓ 2 callers
Method
assertBackupCollection
(String collectionName, int partitionId, int backupCount)
hazelcast/src/test/java/com/hazelcast/collection/impl/AbstractCollectionBackupTest.java:134
↓ 2 callers
Method
assertBackupLogCreationNotForced
(String serviceName)
hazelcast/src/test/java/com/hazelcast/transaction/impl/TransactionContextImpl_backupLogsTest.java:109
↓ 2 callers
Method
assertBackupReplicaVersions
(final Node node, final int partitionId, final long[] expectedRep
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/OperationOutOfOrderBackupTest.java:122
↓ 2 callers
Method
assertBlockingProcessorEventuallyNotRunning
()
hazelcast/src/test/java/com/hazelcast/jet/core/CancellationTest.java:396
↓ 2 callers
Method
assertCachePartitionLostEventEventually
(final EventCollectingCachePartitionLostListener listener,
hazelcast/src/test/java/com/hazelcast/client/cache/ClientCachePartitionLostListenerTest.java:177
↓ 2 callers
Method
assertCachePartitionLostListener
(String listenerName, CacheSimpleConfig cacheConfig)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:1877
↓ 2 callers
Method
assertCachePartitionLostListener
(String listenerName, CacheSimpleConfig cacheConfig)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:1812
↓ 2 callers
Method
assertCacheSizeEventuallyWithTryRecover
(QueryCache cache, int expectedCacheSize)
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheRecreationTest.java:158
↓ 2 callers
Method
assertCacheSizeEventuallyWithTryRecover
(QueryCache cache, int expectedCacheSize)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/ServerQueryCacheRecreationTest.java:145
↓ 2 callers
Method
assertCausedByNoSuchBucketException
(Exception e)
extensions/s3/src/test/java/com/hazelcast/jet/s3/S3TestBase.java:191
↓ 2 callers
Method
assertClassFilterAsMap
(Map<String, Object> filterAsMap)
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGeneratorTest.java:578
↓ 2 callers
Method
assertClassesContains
(Iterable<JavaClass> classes, Class<?> classToFind)
hazelcast-archunit-rules/src/test/java/com/hazelcast/test/archunit/ModuleImportOptionsTest.java:37
↓ 2 callers
Method
assertClientMetricsObservedEventually
(HazelcastInstance memberInstance, MetricsRegistry metricsRegistry,
hazelcast/src/test/java/com/hazelcast/client/internal/metrics/ClientMetricsTest.java:94
↓ 2 callers
Method
assertClusterSizeEventually
(int size)
hazelcast/src/test/java/com/hazelcast/test/ClusterFailureTestSupport.java:211
↓ 2 callers
Method
assertCollectionContainsElements
(final Collection<Long> keys)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/Long2LongHashMapTest.java:267
↓ 2 callers
Method
assertConnectionRemoved
()
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MembershipUpdateTest.java:1048
↓ 2 callers
Method
assertContainsAllEventually
(final Collection<T> collection, final Collection<T> expected)
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapListenerTest.java:487
↓ 2 callers
Method
assertContainsMethods
(String... methodNames)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/JetClassLoaderTest.java:377
↓ 2 callers
Method
assertCopy
(String expected, String actual)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/OperationSerializationTest.java:234
↓ 2 callers
Method
assertCountAggregators
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:242
↓ 2 callers
Method
assertCounterValueEventually
(final long expectedValue, final PNCounter counter)
hazelcast/src/test/java/com/hazelcast/internal/crdt/pncounter/PNCounterSplitBrainTest.java:116
↓ 2 callers
Method
assertCreatedCache
(String cacheName)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheCreateUseDestroyTest.java:176
↓ 2 callers
Method
assertDemotionInvocationStarted
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/DemoteDataMemberTest.java:448
↓ 2 callers
Method
assertDeserializationPass
(JavaSerializationFilterConfig filterConfig)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/DeserializationProtectionTest.java:135
↓ 2 callers
Method
assertDestroyedCache
(String cacheName)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheCreateUseDestroyTest.java:183
↓ 2 callers
Method
assertDiedPeacefully
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/RepartitioningStressTest.java:216
↓ 2 callers
Method
assertDiscoveryConfig
(DiscoveryConfig discoveryConfig)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/TestDiscoveryConfigApplicationContext.java:79
↓ 2 callers
Method
assertDiscoveryConfig
(DiscoveryConfig c)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:2035
↓ 2 callers
Method
assertDiscoveryConfig
(DiscoveryConfig c)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:1999
↓ 2 callers
Method
assertDiscoveryStrategy
(Class<?> clazz)
hazelcast/src/test/java/com/hazelcast/spi/discovery/impl/AutoDetectionDefaultDiscoveryServiceTest.java:79
↓ 2 callers
Method
assertDistinctAggregators
(IMap<Integer, Person> map, String p, Predicate<Integer, Person> predicate)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:254
↓ 2 callers
Method
assertDoesNotContainRow
Execute a query and wait until it completes. Assert that the returned rows does not contain the expected rows, in any order. @param instance Haze
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:369
↓ 2 callers
Method
assertDone
()
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:485
↓ 2 callers
Method
assertEarlyResultsEmittedRepeatedly
(WindowDefinition wDef)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/WindowAggregateTest.java:297
↓ 2 callers
Method
assertEmpty
(Queue<Object> q)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueueImplTest.java:217
↓ 2 callers
Method
assertEmptyPendingInvocationAndWaitSet
(HazelcastInstance server)
hazelcast/src/test/java/com/hazelcast/client/ClientDisconnectTest.java:204
↓ 2 callers
Method
assertEntryIs
(final Entry<Long, Long> entry, final long expectedKey, final long expectedValue)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/Long2LongHashMapTest.java:262
↓ 2 callers
Method
assertEntryIs
(final Entry<String, Long> entry, final String expectedKey, final long expectedValue)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/Object2LongHashMapTest.java:232
↓ 2 callers
Method
assertEntrySetSizeEventually
(final int expectedSize, final Predicate predicate, final QueryC
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheIndexTest.java:273
↓ 2 callers
Method
assertEqualsWithDuplicatesTolerance
(String msg, long expected, long actual)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/RepartitioningStressTest.java:186
↓ 2 callers
Method
assertEurekaConfig
(EurekaConfig eureka)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/TestFullApplicationContext.java:929
↓ 2 callers
Method
assertEventuallyFailsWithHeartbeatTimeout
(final BiConsumer<Object, Throwable> callback)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/Invocation_TimeoutTest.java:329
↓ 2 callers
Method
assertEventuallyNoHikariThreads
(String configName)
hazelcast/src/test/java/com/hazelcast/dataconnection/impl/HikariTestUtil.java:37
↓ 2 callers
Method
assertEventuallyReadYourWriteByContainsKey
(HazelcastInstance instance, ReplicatedMap<String, Integer> map, int value)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapReadYourWritesTest.java:102
↓ 2 callers
Method
assertEventuallyReadYourWriteByContainsValue
(HazelcastInstance instance, ReplicatedMap<String, Integer> map, int value)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapReadYourWritesTest.java:107
↓ 2 callers
Method
assertEventuallyReadYourWriteByGet
(HazelcastInstance instance, ReplicatedMap<String, Integer> map, int value)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapReadYourWritesTest.java:97
↓ 2 callers
Method
assertExecutionMetrics
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/PartialJobMetricsCollectionTest.java:179
↓ 2 callers
Method
assertExpectedOutput
(TestMode mode, List<List<?>> expected, List<List<Object>> actual)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:838
↓ 2 callers
Method
assertFail
(PropertyRules rules, Properties properties, String messageExpected)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/impl/PropertyRulesTest.java:56
↓ 2 callers
Method
assertFailure
(ClientMessage clientMessage, String expectedExceptionMsg)
hazelcast/src/test/java/com/hazelcast/internal/management/operation/DisabledOperationsTest.java:77
↓ 2 callers
Method
assertFieldsAreNull
(Collection<Employee> matchingEmployees)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryIndexingTest.java:151
↓ 2 callers
Method
assertFieldsCanBeAdded
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:206
↓ 2 callers
Method
assertFilesRollingOver
(DiagnosticsConfig diagnosticsConfig)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsLogFileTest.java:156
↓ 2 callers
Method
assertFitsInt
(long arg)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/ByteArrayAccessStrategy.java:43
↓ 2 callers
Method
assertFragments
(List<ClientMessage> fragments, ClientMessage.ForwardFrameIterator originalIterator)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/util/ClientMessageSplitterTest.java:86
↓ 2 callers
Method
assertGcpConfig
(GcpConfig gcp)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/TestFullApplicationContext.java:904
↓ 2 callers
Method
assertGlobalIndexesAreInitialized
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:168
↓ 2 callers
Method
assertInitialMembershipEvent
(EventObject e, Member... expectedMembers)
hazelcast/src/test/java/com/hazelcast/cluster/ClusterMembershipListenerTest.java:238
↓ 2 callers
Method
assertInstanceStarted
(String instanceName)
hazelcast/src/test/java/com/hazelcast/cache/CachingProviderTest.java:232
↓ 2 callers
Method
assertIteratorHasElements
()
hazelcast/src/test/java/com/hazelcast/internal/util/collection/IntHashSetTest.java:297
↓ 2 callers
Method
assertIteratorHasElements
()
hazelcast/src/test/java/com/hazelcast/internal/util/collection/LongHashSetTest.java:341
↓ 2 callers
Method
assertJSONContainsClassNameJustOnce
(JsonObject jsonObject1, JsonObject jsonObject2, String className)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetectorAbstractTest.java:163
↓ 2 callers
Method
assertJobActive
(String name, Job job)
hazelcast/src/main/java/com/hazelcast/client/console/HazelcastCommandLine.java:592
↓ 2 callers
Method
assertJobCompleted
(Job job)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/jet/SpringServiceFactoriesTest.java:111
↓ 2 callers
Method
assertJobHasExecutionMetricsEventually
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/MetricsTest.java:463
↓ 2 callers
Method
assertJobRunning
(String name, Job job)
hazelcast/src/main/java/com/hazelcast/client/console/HazelcastCommandLine.java:598
↓ 2 callers
Method
assertJobStatsOnMember
(HazelcastInstance instance, int submitted, int executionsStarted, int
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobLifecycleMetricsTest.java:338
↓ 2 callers
Method
assertJoinMemberListVersions
(HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MemberListJoinVersionTest.java:139
↓ 2 callers
Method
assertJsonContains
(String uri, String json, String... attributesAndValues)
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestClusterBadRequestTest.java:142
↓ 2 callers
Method
assertKeyExistsInCache
(final String expectedValue, final Integer key, final String cacheName
hazelcast/src/test/java/com/hazelcast/cache/entryprocessor/CacheEntryProcessorTest.java:166
↓ 2 callers
Method
assertKubernetesConfig
(KubernetesConfig kubernetes)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/TestFullApplicationContext.java:921
↓ 2 callers
Method
assertLastUpdateTime
(Runnable runnable, boolean updated)
hazelcast/src/test/java/com/hazelcast/internal/monitor/impl/LocalRecordStoreStatsImplTest.java:214
↓ 2 callers
Method
assertLastUpdateTime
(Runnable runnable, boolean updated)
hazelcast/src/test/java/com/hazelcast/internal/monitor/impl/LocalRecordStoreStatsImplOffloadingTest.java:84
↓ 2 callers
Method
assertLeastInvalidationCount
(final int leastInvalidationCount)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheInvalidationTest.java:535
↓ 2 callers
Method
assertListOfObjects
(List<TestJsonObject> list)
hazelcast/src/test/java/com/hazelcast/jet/impl/util/JsonUtilTest.java:275
↓ 2 callers
Method
assertListenerCount
(int expected, String cacheName)
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheCreateUseDestroyTest.java:191
↓ 2 callers
Method
assertLoaderIsClosedEventually
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreEvictionTest.java:209
↓ 2 callers
Method
assertLocalPortsOpen
(int... ports)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AdvancedNetworkIntegrationTest.java:243
↓ 2 callers
Method
assertLockCount
(int expectedCount)
hazelcast/src/test/java/com/hazelcast/spi/LockInterceptorServiceTest.java:106
↓ 2 callers
Method
assertMBeanContains
(String... expectedObjectNames)
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTestHelper.java:78
↓ 2 callers
Method
assertMapPartitionLostEventEventually
(final TestEventCollectingMapPartitionLostListener listener,
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapPartitionLostListenerTest.java:139
↓ 2 callers
Method
assertMapPartitionLostListener
(String listenerName, MapConfig mapConfig)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:1839
← previous
next →
16,401–16,500 of 147,315, ranked by callers