Migrates the backing memory region to a new allocator, freeing the current region. Memory allocated by the new allocator must be accessible by the sam

Returns {@code true} if there are no migrations in the migration queue, no new node is joining, there is no ongoing repartitioning, otherwise triggers

Sorts the objects from multiple inputs into an order in which they will be passed to processor, based on priorities.

Convenience for {@link #builder}. Example usage: <pre>{@code Sink<Document> mongoSink = MongoSinks.mongodb( "mongodb://127.0.

Read-only and not thread-safe iterator. <p> Returned iterator from this method doesn't throw {@link java.util.ConcurrentModificationException} to fail

Returns a {@link Collection} object for a given collection interface. @return a new Collection object of a class that is assignable from the given ty

NOT IMPLEMENTED. Fails by throwing {@link UnsupportedOperationException}. <p> May the force be the one who dares to implement a linearizable distribut

Creates new {@link AliasedDiscoveryConfig} by the given {@code tag}.

Creates new {@link Credentials} object. @return the new Credentials object

Instantiates a new instance of the {@link DiscoveryService}. @param settings The settings to pass to creation of the <code>DiscoveryService</code> @r

Instantiates a new instance of the {@link DiscoveryStrategy} with the given configuration properties. The provided {@link HazelcastInstance} can be us

Creates a Hazelcast 3 member with Hazelcast 4 interface It translates method calls using a Mockito based proxy. It is not fully tested, see {@link Ha

Create a job proxy for a submitted job. {@code lightJobCoordinator} must be non-null iff it's a light job.

Returns the factory of the watermark policy objects.