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
↓ 6 callers
Method
assertCommitCalled
()
hazelcast/src/test/java/com/hazelcast/transaction/impl/MockTransactionLogRecord.java:103
↓ 6 callers
Method
assertContainsCounterStatsEventually
(final boolean contains, final HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/internal/crdt/pncounter/PNCounterStatisticsSplitBrainTest.java:92
↓ 6 callers
Method
assertContainsSubsetOfRows
Asserts that the result of {@code sql} contains a subset of {@code expectedRows}, the subset must be of size {@code subsetSize}.
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlLimitTest.java:260
↓ 6 callers
Method
assertContents
(Map<Member, List<IScheduledFuture<Double>>> futuresPerMember)
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorSplitBrainTest.java:247
↓ 6 callers
Method
assertExecutionTerminated
()
hazelcast/src/test/java/com/hazelcast/jet/core/CancellationTest.java:385
↓ 6 callers
Method
assertExpectedUuids
(String testName, Collection<UUID> expectedUuids)
hazelcast/src/test/java/com/hazelcast/internal/util/SerialOperationInvokerTest.java:301
↓ 6 callers
Method
assertFail
(String jsonResult)
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:219
↓ 6 callers
Method
assertFalseKV
(boolean actual, long key, long value)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/Long2LongMapHsaTest.java:459
↓ 6 callers
Method
assertFitsInt
(long arg)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/HeapMemoryManager.java:153
↓ 6 callers
Method
assertHigherPriorityVertices
(Vertex... vertices)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/init/VertexDef_HigherPrioritySourceTest.java:134
↓ 6 callers
Method
assertIndependentClusters
(Config config1, Config config2)
hazelcast/src/test/java/com/hazelcast/cluster/AbstractJoinTest.java:104
↓ 6 callers
Method
assertInvokedOnlyOnMembers
(HazelcastInstance... members)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlEndToEndTestSupport.java:170
↓ 6 callers
Method
assertIsCompatibleSelf
(ConfigCheck c1)
hazelcast/src/test/java/com/hazelcast/cluster/ConfigCheckTest.java:160
↓ 6 callers
Method
assertIterationResult
(IterationResult<Integer> result, UUID prevCursorId, UUID cursorIdToForget, int start,
hazelcast/src/test/java/com/hazelcast/internal/iteration/IteratorWithCursorTest.java:125
↓ 6 callers
Method
assertJobIsRunning
(JetService jetService)
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/upload/JobUploadClientFailureTest.java:506
↓ 6 callers
Method
assertJobSucceeded
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/core/ExecutionLifecycleTest.java:1230
↓ 6 callers
Method
assertJsonContains
(String json, String... attributesAndValues)
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestTest.java:487
↓ 6 callers
Method
assertMasterAddressEventually
(final Address masterAddress, final HazelcastInstance...
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1083
↓ 6 callers
Method
assertMigrationEventsConsistentWithResult
(MigrationEventsPack eventsPack)
hazelcast/src/test/java/com/hazelcast/partition/PartitionMigrationListenerTest.java:201
↓ 6 callers
Method
assertMigrationProcessCompleted
(MigrationEventsPack eventsPack)
hazelcast/src/test/java/com/hazelcast/partition/PartitionMigrationListenerTest.java:185
↓ 6 callers
Method
assertNearCacheSizeEventually
(final IMap map, final int nearCacheSize)
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/ClientMapNearCacheInvalidationTest.java:382
↓ 6 callers
Method
assertNoInteractionWith
(SimpleInterceptor interceptor)
hazelcast/src/test/java/com/hazelcast/map/EmbeddedMapInterceptorTest.java:282
↓ 6 callers
Method
assertNoLeakingClient
Check if we removed all client object related references from {@link OutOfMemoryErrorDispatcher} and {@link HazelcastClient} internal client registry.
hazelcast/src/test/java/com/hazelcast/client/TestHazelcastFactoryTest.java:105
↓ 6 callers
Method
assertNoOfDistributedObject
(String message, int expected, Collection<DistributedObject> distributedObjects)
hazelcast/src/test/java/com/hazelcast/client/ClientRegressionWithMockNetworkTest.java:186
↓ 6 callers
Method
assertOnCoordinatorThread
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1541
↓ 6 callers
Method
assertOpenEventually
(CountDownLatch latch)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/TpcTestSupport.java:165
↓ 6 callers
Method
assertOpenShards
(int count, Shard... excludedShards)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisIntegrationTest.java:621
↓ 6 callers
Method
assertPClosedWithError
()
hazelcast/src/test/java/com/hazelcast/jet/core/ExecutionLifecycleTest.java:1213
↓ 6 callers
Method
assertPartitionAssignments
()
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionCorrectnessTestSupport.java:169
↓ 6 callers
Method
assertPolledRecordsSize
(int expected)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/TaskRunnerTest.java:155
↓ 6 callers
Method
assertProbeExist
(ProbeLevel probeLevel, ProbeLevel minimumLevel)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/ProbeLevelTest.java:63
↓ 6 callers
Method
assertRecordStored
(K key, V value, long expectedExpirationTime, long delta)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/TestEntryStore.java:167
↓ 6 callers
Method
assertRegistrationsSizeEventually
(final HazelcastInstance instance, final String serviceName, final String topic, final int size)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/BasicClusterStateTest.java:445
↓ 6 callers
Method
assertSameLastUpdateTime
()
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapContainerStatisticsTest.java:206
↓ 6 callers
Method
assertSourceSinkTags
(JobMetrics metrics, String vertexName, boolean beforeRestart, boolean e
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/MetricsTest.java:470
↓ 6 callers
Method
assertSuccess
(String jsonResult)
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:224
↓ 6 callers
Method
assertTestObjectAsMap
(Map<String, Object> objectMap, TestJsonObject testJsonObject)
hazelcast/src/test/java/com/hazelcast/jet/impl/util/JsonUtilTest.java:293
↓ 6 callers
Method
assertTextInSystemOut
Asserts that given substring in in standard output buffer. Calling this method resets the buffer.
hazelcast/src/test/java/com/hazelcast/client/console/ClientConsoleAppTest.java:173
↓ 6 callers
Method
assertTextInSystemOut
Asserts that given substring in standard output buffer. Calling this method resets the buffer. @param substring a substring that asserted to be in st
hazelcast/src/test/java/com/hazelcast/console/ConsoleAppTest.java:152
↓ 6 callers
Method
assertThrows
(Class<? extends Exception> expectedExceptionClass, ConsumerEx<Ringbuffer<Object
hazelcast/src/test/java/com/hazelcast/ringbuffer/AbstractRingbufferNullTest.java:45
↓ 6 callers
Method
assertTopicContentsEventually
( String topic, Map<Integer, String> expected, boolean assertPartitionEqua
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:321
↓ 6 callers
Method
assertTrueDelayed5sec
(AssertTask task)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1340
↓ 6 callers
Method
assertTrueEventuallyFast
(Runnable r)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/QueryUtilsTest.java:180
↓ 6 callers
Method
assertUUID_And_AddressesRemoved
(UUID memberUuid, Set<Address> addresses)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/LocalAddressRegistryTest.java:193
↓ 6 callers
Method
assertUniques
(HashSet<String> readKeys, Iterator<Cache.Entry<String, String>> iterator)
hazelcast/src/test/java/com/hazelcast/cache/CachePartitionIteratorMigrationTest.java:119
↓ 6 callers
Method
assertUniques
(HashSet<String> readKeys, Iterator<Map.Entry<String, String>> iterator)
hazelcast/src/test/java/com/hazelcast/map/AbstractMapPartitionIteratorTest.java:211
↓ 6 callers
Method
assertUniques
(HashSet<String> readKeys, Iterator<Map.Entry<String, String>> iterator)
hazelcast/src/test/java/com/hazelcast/map/AbstractMapIteratorTest.java:228
↓ 6 callers
Method
assertWriteBehindQueuesEmpty
(final String mapName, final List<HazelcastInstance> nodes)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindFlushTest.java:244
↓ 6 callers
Method
assertXmlYamlFileEquals
(String filenameBase)
hazelcast/src/test/java/com/hazelcast/config/XmlYamlConfigBuilderEqualsTest.java:210
↓ 6 callers
Method
attachMapUsingServiceAsyncBatched
( @Nonnull ServiceFactory<?, S> serviceFactory, int maxBatchSize, @Nonnull
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:318
↓ 6 callers
Method
attachedDirectory
Uses the supplied ID to look up a directory you attached to the current Jet job. Creates a temporary directory with the same contents on the local clu
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorSupplier.java:142
↓ 6 callers
Method
attemptingToConnectToAddress
Triggered before trying to connect to an address. This event is triggered after a {@link #possibleAddressesCollected(List)} event, and the {@code addr
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListener.java:53
↓ 6 callers
Method
authHeader
(Map<String, String> attributes, Map<String, String> headers, String body, AwsCredential
hazelcast/src/main/java/com/hazelcast/aws/AwsRequestSigner.java:53
↓ 6 callers
Method
awaitSlowEntryProcessors
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/slowoperationdetector/SlowOperationDetectorAbstractTest.java:183
↓ 6 callers
Method
awaitStable
(String mapName, HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/map/IndexStatsChangingNumberOfMembersTest.java:434
↓ 6 callers
Method
batch
Creates as builder for new batch mongo source. Equivalent to calling {@link MongoSourceBuilder#batch}. <p> Example usage: <pre>{@code BatchSource<MyDT
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSources.java:67
↓ 6 callers
Method
batchSource
()
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:313
↓ 6 callers
Method
beginPartitionUpdate
Notifies the index that a partition update is about to begin. Could be caused be either partition add (e.g. migration from another member, dynamic ind
hazelcast/src/main/java/com/hazelcast/query/impl/InternalIndex.java:77
↓ 6 callers
Method
beginPartitionUpdate
()
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalIndexPartitionTracker.java:88
↓ 6 callers
Method
beginPartitionUpdate
(InternalIndex[] indexes)
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:120
↓ 6 callers
Method
bigDecimalMax
@param <I> type of the input object. @return an aggregator that calculates the max of the input values. Accepts null input values. Accepts only BigDec
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:269
↓ 6 callers
Method
bigDecimalMin
@param <I> type of the input object. @return an aggregator that calculates the min of the input values. Accepts null input values and null extracted v
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:425
↓ 6 callers
Method
bigEndian
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:385
↓ 6 callers
Method
bigEndian
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataOutputStream.java:306
↓ 6 callers
Method
bigIntegerMax
@param <I> type of the input object. @return an aggregator that calculates the max of the input values. Accepts null input values and null extracted v
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:292
↓ 6 callers
Method
bigIntegerMin
@param <I> type of the input object. @return an aggregator that calculates the min of the input values. Accepts null input values and null extracted v
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:448
↓ 6 callers
Method
blockSnapshot
()
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:125
↓ 6 callers
Method
buildClient
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/AwsConfig.java:101
↓ 6 callers
Method
buildConfig
()
hazelcast/src/test/java/com/hazelcast/client/config/XmlClientFailoverConfigBuilderTest.java:124
↓ 6 callers
Method
buildConfig
(String yaml)
hazelcast/src/test/java/com/hazelcast/config/YamlOnlyConfigBuilderTest.java:142
↓ 6 callers
Method
buildDag
()
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamFilesP_integrationTest.java:276
↓ 6 callers
Method
buildDom
(String rootName, Object document)
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlLoader.java:150
↓ 6 callers
Method
buildKubernetesClient
()
hazelcast/src/test/java/com/hazelcast/kubernetes/StsMonitorTest.java:89
↓ 6 callers
Method
c_notComposite
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/index/SqlIndexAbstractTest.java:673
↓ 6 callers
Method
cacheEntryListenerCountIncreasedAndDecreasedCorrectly
(DecreaseType decreaseType)
hazelcast/src/test/java/com/hazelcast/cache/CacheContextTest.java:86
↓ 6 callers
Method
canConvertTo
(QueryDataTypeFamily typeFamily)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:298
↓ 6 callers
Method
cartesian
(List<Tuple2<T1, T2>> list1, List<T
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroTest.java:921
↓ 6 callers
Method
cartesianProduct
Returns the cartesian product of the specified lists.
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:389
↓ 6 callers
Method
character
(char expected)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/util/ThreadAffinity.java:282
↓ 6 callers
Method
check
(final Object obj)
hazelcast/src/test/java/com/hazelcast/partition/strategy/AttributePartitioningStrategyTest.java:129
↓ 6 callers
Method
checkEvictionConfig
Checks if a {@link EvictionConfig} is valid in its context. @param evictionConfig the {@link EvictionConfig}
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigValidator.java:423
↓ 6 callers
Method
checkMapConfig
(MapConfig expectedConfig, MapConfig actualConfig)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:282
↓ 6 callers
Method
checkNearCacheNativeMemoryConfig
Checks precondition to use {@link InMemoryFormat#NATIVE}. @param inMemoryFormat the {@link InMemoryFormat} of the Near Cache @param nativeMemoryC
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigValidator.java:458
↓ 6 callers
Method
checkParameter
(Object param, Object expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/FloorCeilFunctionIntegrationTest.java:152
↓ 6 callers
Method
checkPlan
(boolean withIndex, boolean sorted, String sql)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlCreateIndexTest.java:196
↓ 6 callers
Method
checkRemote
(@Nullable String clientXml, @Nonnull Permission permission)
hazelcast/src/main/java/com/hazelcast/security/PermissionsUtil.java:46
↓ 6 callers
Method
checkServiceNameNotNull
(@Nonnull String serviceName)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/ProxyServiceImpl.java:300
↓ 6 callers
Method
checkSnapshots
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:892
↓ 6 callers
Method
checkSuccess
(String fieldName, String tableFqn, String... tableComponents)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/parse/ParserNameResolutionTest.java:121
↓ 6 callers
Method
checkThreadLocalsForLeaks
(ClassLoader cl)
hazelcast/src/test/java/classloading/ThreadLocalLeakTestUtils.java:50
↓ 6 callers
Method
checkTransactionActive
()
hazelcast/src/main/java/com/hazelcast/multimap/impl/txn/TransactionalMultiMapProxySupport.java:108
↓ 6 callers
Method
child
Gets a child node by its index @param index the index of the child node @return the child node with the given index if exists, {@code null} otherwise
hazelcast/src/main/java/com/hazelcast/internal/config/yaml/YamlOrderedMapping.java:34
↓ 6 callers
Method
classForType
(QueryDataTypeFamily type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionValue.java:62
↓ 6 callers
Method
clazz
@return class name of registered data connection.
hazelcast/src/main/java/com/hazelcast/dataconnection/DataConnectionRegistration.java:36
↓ 6 callers
Method
clearAll
Clears contents of indexes managed by this instance.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:286
↓ 6 callers
Method
clearCachedMetricSourceRef
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/AbstractGauge.java:99
↓ 6 callers
Method
clientSupplier
()
extensions/s3/src/test/java/com/hazelcast/jet/s3/S3TestBase.java:161
↓ 6 callers
Method
clone
Returns a shallow copy of this <tt>InflatableSet</tt> instance: the keys and values themselves are not cloned. @return a shallow copy of this set
hazelcast/src/main/java/com/hazelcast/internal/util/collection/InflatableSet.java:193
↓ 6 callers
Method
cloneExceptionWithFixedAsyncStackTrace
@param original exception to be cloned with fixed stack trace @param <T> type of the original exception @return a cloned exception with the curre
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:327
↓ 6 callers
Method
coalesce
(Expression<?>... operands)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/CaseExpression.java:58
← previous
next →
9,101–9,200 of 147,315, ranked by callers