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 callersMethodassertThatScheduledTaskHandlerAreEqual
(ScheduledTaskHandler expected, ScheduledTaskHandler actual)
hazelcast/src/test/java/com/hazelcast/test/starter/constructor/test/ScheduledTaskHandlerImplConstructorTest.java:55
↓ 2 callersMethodassertThreadsEventuallyFinishesWithoutException
(StressThread[] threads)
hazelcast/src/test/java/com/hazelcast/logging/LoggerStressTest.java:72
↓ 2 callersMethodassertThrows
(Class<? extends Exception> expectedExceptionClass, ConsumerEx<IQueue<Object>> m
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/AbstractQueueNullTest.java:60
↓ 2 callersMethodassertThrows
(Class<? extends Exception> expectedExceptionClass, ConsumerEx<SplitBrainProtect
hazelcast/src/test/java/com/hazelcast/quorum/AbstractQuorumServiceNullTest.java:42
↓ 2 callersMethodassertThrows
(Class<? extends Exception> expectedExceptionClass, ConsumerEx<PartitionService>
hazelcast/src/test/java/com/hazelcast/partition/AbstractPartitionServiceNullTest.java:40
↓ 2 callersMethodassertThrows
(Class<? extends Exception> expectedExceptionClass, ConsumerEx<Cluster> method)
hazelcast/src/test/java/com/hazelcast/cluster/AbstractClusterNullTest.java:51
↓ 2 callersMethodassertThrowsNPE
(ConsumerEx<LifecycleService> method)
hazelcast/src/test/java/com/hazelcast/AbstractLifecycleServiceNullTest.java:38
↓ 2 callersMethodassertThrowsNPE
(ConsumerEx<SplitBrainProtectionService> method)
hazelcast/src/test/java/com/hazelcast/quorum/AbstractQuorumServiceNullTest.java:38
↓ 2 callersMethodassertThrowsNPE
(ConsumerEx<CardinalityEstimator> method)
hazelcast/src/test/java/com/hazelcast/cardinality/AbstractCardinalityEstimatorNullTest.java:37
↓ 2 callersMethodassertTls13SupportInternal
(String caFileName)
hazelcast/src/test/java/com/hazelcast/spi/utils/RestClientTest.java:251
↓ 2 callersMethodassertTotalQueueSize
(final int expectedQueueSize)
hazelcast/src/test/java/com/hazelcast/wan/impl/AbstractWanCustomPublisherMapTest.java:268
↓ 2 callersMethodassertTransactionMapSize
(HazelcastInstance instance, String name, int size)
hazelcast/src/test/java/com/hazelcast/collection/impl/txnqueue/TransactionQueueTest.java:576
↓ 2 callersMethodassertTrueTwoSeconds
(AssertTask task)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/TpcTestSupport.java:133
↓ 2 callersMethodassertTtlFromLocalRecordStore
(HazelcastInstance instance, Data key, long expectedTtl)
hazelcast/src/test/java/com/hazelcast/map/EntryProcessorTest.java:1021
↓ 2 callersMethodassertTwoStageAggregation
(boolean isRebalanceByKey)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/RebalanceStreamStageTest.java:226
↓ 2 callersMethodassertUnexpectedFuturesHaveMergedValue
()
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorSplitBrainTest.java:303
↓ 2 callersMethodassertUnresponsiveMasterOperationStartedOnMaster
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/Invocation_OnMemberLeftTest.java:207
↓ 2 callersMethodassertUnresponsiveTargetOperationStarted
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/Invocation_OnMemberLeftTest.java:203
↓ 2 callersMethodassertUnsupported
(Method m, Object value)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/HsaHeapMemoryManagerTest.java:136
↓ 2 callersMethodassertUsedFreeHeapPolicyTriggersEviction
(final Collection<IMap> maps)
hazelcast/src/test/java/com/hazelcast/map/EvictionMaxSizePolicyTest.java:522
↓ 2 callersMethodassertValidWaitingOperationCount
(final int count)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientTxnDisconnectionTest.java:110
↓ 2 callersMethodassertValueEquals
(EJ_TYPE event, Object expectedValue)
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalBasicTest.java:624
↓ 2 callersMethodassertValuesSizeEventually
(final int expectedSize, final Predicate predicate, final QueryCac
hazelcast/src/test/java/com/hazelcast/client/map/impl/querycache/ClientQueryCacheIndexTest.java:284
↓ 2 callersMethodassertWanBatchPublisherEqual
(WanBatchPublisherConfig expected, WanBatchPublisherConfig actual)
hazelcast/src/test/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/WanReplicationConfigTransformerTest.java:204
↓ 2 callersMethodassertWanConsumerConfig
(WanConsumerConfig expected, WanConsumerConfig actual)
hazelcast/src/test/java/com/hazelcast/config/WanConsumerConfigTest.java:57
↓ 2 callersMethodassertWanPublisherConfig
(WanBatchPublisherConfig expected, WanBatchPublisherConfig actual)
hazelcast/src/test/java/com/hazelcast/config/WanBatchPublisherConfigTest.java:85
↓ 2 callersMethodassertWanReplicationConfig
(WanReplicationConfig expected, WanReplicationConfig actual)
hazelcast/src/test/java/com/hazelcast/config/WanReplicationConfigTest.java:90
↓ 2 callersMethodassignSplitsToMembers
Heuristically solves the following problem: <ul><li> HDFS stores a file by dividing it into blocks and storing each block on several machines. </li><l
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/impl/ReadHdfsMetaSupplierBase.java:123
↓ 2 callersMethodassumeConfiguredByteOrder
Throws {@link AssumptionViolatedException} if the given {@link InternalSerializationService} is not configured with the assumed {@link ByteOrder}. @p
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1633
↓ 2 callersMethodassumeLastSnapshotPresent
@param snapshotId snapshot id for the last snapshot (including in progress), or -1 if no snapshot is expected
hazelcast/src/test/java/com/hazelcast/jet/core/IndeterminateSnapshotTest.java:218
↓ 2 callersMethodassumeNoArm64Architecture
()
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1614
↓ 2 callersMethodassumeNotZing
Zing (Azul Prime) has problems with mocks of some internal objects, like Node or HazelcastInstance. If the tests are using such mocks and cannot avoid
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1645
↓ 2 callersMethodassumeOperatingSystemMXBeanType
(String expected)
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/OperatingSystemMetricSetTest.java:108
↓ 2 callersMethodassumeTestDatabaseProviderIsNotInstanceOf
(TestDatabaseProvider provider, String messag
hazelcast/src/test/java/com/hazelcast/test/DockerTestUtil.java:45
↓ 2 callersMethodassumptions
()
hazelcast/src/test/java/com/hazelcast/cache/impl/CacheCreateUseDestroyTest.java:115
↓ 2 callersMethodassureEnoughMemoryLeft
(long size)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/HeapMemoryManager.java:128
↓ 2 callersMethodasyncCallsDone
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/AsyncHazelcastWriterP.java:162
↓ 2 callersMethodatUtc
{@link #atLocal()} converted to UTC. If system timezone is UTC, result is identical; if for example system timezone is CET, then result will be 1 hour
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/AllTypesSelectMongoSqlConnectorIT.java:132
↓ 2 callersMethodattachCustomTransform
( @Nonnull String stageName, @Nonnull ProcessorMetaSupplier procSupplier )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:535
↓ 2 callersMethodattachDirectoryPipeline
(String attachedDirectory)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/AbstractDeploymentTest.java:230
↓ 2 callersMethodattachFileOrDir
(String id, @Nonnull File file)
hazelcast/src/main/java/com/hazelcast/jet/pipeline/ServiceFactory.java:308
↓ 2 callersMethodattachFilePipeline
(String attachedFile)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/AbstractDeploymentTest.java:185
↓ 2 callersMethodattachFilter
(@Nonnull PredicateEx<T> filterFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:153
↓ 2 callersMethodattachFlatMap
( @Nonnull FunctionEx<? super T, ? extends Traverser<R>> flatMapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:161
↓ 2 callersMethodattachGlobalFlatMapStateful
( @Nonnull SupplierEx<? extends S> createFn, @Nonnull BiFunctionEx<? super S, ? super
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:187
↓ 2 callersMethodattachMap
(@Nonnull FunctionEx<? super T, ? extends R> mapFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:146
↓ 2 callersMethodattachMapUsingPartitionedServiceAsyncBatched
( @Nonnull ServiceFactory<?, S> serviceFactory, int maxBatchSize, @Nonnull
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:426
↓ 2 callersMethodattachMerge
(@Nonnull GeneralStage<? extends T> other)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:470
↓ 2 callersMethodattachPartitionedCustomTransform
( @Nonnull String stageName, @Nonnull ProcessorMetaSupplier procSupplier,
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:543
↓ 2 callersMethodattachPeek
( @Nonnull PredicateEx<? super T> shouldLogFn, @Nonnull FunctionEx<? super T, ? extend
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:519
↓ 2 callersMethodattachSort
(@Nullable ComparatorEx<? super T> comparator)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:141
↓ 2 callersMethodattachedFile
(@Nonnull String id)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestProcessorSupplierContext.java:110
↓ 2 callersMethodattachedFiles
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/PipelineImpl.java:195
↓ 2 callersMethodattemptToSendGetRecordsRequest
(long currentTime)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardReader.java:273
↓ 2 callersMethodauthenticateOnCluster
(TcpClientConnection connection)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:1026
↓ 2 callersMethodauthenticated
(UUID clientUuid, Credentials credentials, String clientVersion, long authCorrel
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointImpl.java:124
↓ 2 callersMethodauthenticationSuccess
Triggered when the client received acknowledgement of successful authentication from a member.
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListener.java:88
↓ 2 callersMethodautoDetectionConfigXmlGenerator
(XmlGenerator gen, JoinConfig join)
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:725
↓ 2 callersMethodautoDetectionConfigYamlGenerator
(Map<String, Object> parent, JoinConfig joinConfig)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGenerator.java:822
↓ 2 callersMethodautoDisposable
(Runnable runnable)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/AutoDisposableTaskDecorator.java:45
↓ 2 callersMethodavailableMemoryInBytes
()
hazelcast/src/main/java/com/hazelcast/map/impl/eviction/EvictionChecker.java:177
↓ 2 callersMethodavgMicros
()
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:133
↓ 2 callersMethodavoidOverlappingTerminations
Wait for cluster reaching safe state after member is terminated before next member is terminated. This avoids data loss in scenarios with totalBackupC
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:574
↓ 2 callersMethodawait
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/ClientExecutionServiceImplTest.java:115
↓ 2 callersMethodawait
()
hazelcast/src/test/java/com/hazelcast/internal/adapter/ICacheCompletionListener.java:43
↓ 2 callersMethodawait
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindStaleReadTest.java:104
↓ 2 callersMethodawaitBarrier
(CyclicBarrier barrier)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationExecutorImpl_BasicTest.java:168
↓ 2 callersMethodawaitExecutionStarted
()
hazelcast/src/test/java/com/hazelcast/spi/impl/executionservice/impl/DelegateAndSkipOnConcurrentExecutionDecoratorTest.java:125
↓ 2 callersMethodawaitLatch
(CountDownLatch countDownLatch, InternalCompletableFuture future)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheSyncListenerCompleter.java:122
↓ 2 callersMethodawaitPause
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/PausingMapLoader.java:76
↓ 2 callersMethodawaitTaskCancelAtMember
(final HazelcastInstance member, final long cancelledTaskCount)
hazelcast/src/test/java/com/hazelcast/client/executor/ClientExecutorServiceCancelTest.java:321
↓ 2 callersMethodawaitTermination
(OperationThread[] operationThreads)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationExecutorImpl.java:605
↓ 2 callersMethodbackgroundClearTaskStops_whenLifecycleState
(LifecycleEvent.LifecycleState lifecycleState)
hazelcast/src/test/java/com/hazelcast/internal/eviction/MapExpirationManagerTest.java:269
↓ 2 callersMethodbackgroundClearTaskStops_whenLifecycleState
(LifecycleEvent.LifecycleState lifecycleState)
hazelcast/src/test/java/com/hazelcast/internal/eviction/CacheExpirationManagerTest.java:191
↓ 2 callersMethodbackup
()
hazelcast/src/main/java/com/hazelcast/internal/hotrestart/NoOpHotRestartService.java:30
↓ 2 callersMethodbackup
Attempts to perform a cluster-wide data backup. Each node will create a directory under the defined backup dir with the name {@link #BACKUP_DIR_PREFIX
hazelcast/src/main/java/com/hazelcast/persistence/PersistenceService.java:38
↓ 2 callersMethodbackupsShouldNotBeIndexed
(boolean migrationHappens)
hazelcast/src/test/java/com/hazelcast/map/MapIndexBackupTest.java:67
↓ 2 callersMethodbatchFilters
(Batch<?> sourceBuilder)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/MongoSourceTest.java:182
↓ 2 callersMethodbefore
(ClientConfig config)
hazelcast/src/test/java/com/hazelcast/client/flakeidgen/impl/FlakeIdGenerator_ClientIntegrationTest.java:45
↓ 2 callersMethodbeforeRun
The beforeRun is called before either the {@link #run()} or the {@link #call()} method is called. <p> runs before wait-support
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:136
↓ 2 callersMethodbeforeRun
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/operations/Backup.java:111
↓ 2 callersMethodbeginExecution
Starts local execution of job by submitting tasklets to execution service. If execution was cancelled earlier then execution will not be started. <p>
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ExecutionContext.java:224
↓ 2 callersMethodbeginExecution0
(ExecutionContext execCtx, boolean collectMetrics)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionService.java:566
↓ 2 callersMethodbeginIndexMarking
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MergeOperation.java:194
↓ 2 callersMethodbeginTransaction
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionContextImpl.java:66
↓ 2 callersMethodbidirectionalStreamingService
Creates a {@link ServiceFactory} that calls out to a <a href="https://grpc.io/docs/guides/concepts/#bidirectional-streaming-rpc"> bidirectional stream
extensions/grpc/src/main/java/com/hazelcast/jet/grpc/GrpcServices.java:163
↓ 2 callersMethodbindSocketToPort
(Socket socket)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:774
↓ 2 callersMethodbitSetCopy
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/PartitionIdSet.java:292
↓ 2 callersMethodblock
()
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:185
↓ 2 callersMethodblockOnConnect
blocks the caller thread until a connection is established (or failed) or the time runs out. Callers must ensure a connection is established after thi
hazelcast/src/main/java/com/hazelcast/internal/server/ServerConnectionManager.java:270
↓ 2 callersMethodbootstrappedInstance
@since Jet 4.0 @deprecated Please use {@link Hazelcast#bootstrappedInstance()} and then get {@link JetService} from the created {@link HazelcastInstan
hazelcast/src/main/java/com/hazelcast/jet/Jet.java:51
↓ 2 callersMethodbroadcastUpdateDataConnectionOperations
(@Nonnull String dataConnectionName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/PlanExecutor.java:854
↓ 2 callersMethodbsonDateTimeToLocalDateTime
Converts given bson timestamp to unix epoch.
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/MongoUtilities.java:130
↓ 2 callersMethodbuild
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncSocketBuilder.java:138
↓ 2 callersMethodbuild
()
hazelcast/src/main/java/com/hazelcast/client/config/YamlClientFailoverConfigBuilder.java:127
↓ 2 callersMethodbuild
()
hazelcast/src/main/java/com/hazelcast/client/config/XmlClientFailoverConfigBuilder.java:143
↓ 2 callersMethodbuild
()
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfigBuilder.java:44
↓ 2 callersMethodbuild0
(BiFunctionEx<T0, ItemsByTag, R> mapToOutputFn)
hazelcast/src/main/java/com/hazelcast/jet/pipeline/GeneralHashJoinBuilder.java:109
↓ 2 callersMethodbuildChildren
(YamlMappingImpl parentNode, Map<String, Object> mapNode)
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlDomBuilder.java:92
↓ 2 callersMethodbuildCollationTrait
Builds a collation with collation fields re-mapped according to the table projections. @param scan the logical map scan @param index the index @para
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:983
← previousnext →16,601–16,700 of 147,315, ranked by callers