Resets {@link PartitionSequencer}. After this call returns sequence generation will be start from zero.

Resets the iteration state.

Resets the iteration state.

Get the actual threshold which when reached the map resize. This is a function of the current capacity and load factor. @return the threshold when th

Get the actual threshold which when reached the map resize. This is a function of the current capacity and load factor. @return the threshold when th

Allocates a new slot array with the requested size and moves all the assigned slots from the current array into the new one.

@return resolved endpoint qualifier when it is passed from the user via configuration

@see org.apache.kafka.common.serialization.Serdes#serdeFrom(Class) @see com.hazelcast.jet.sql.impl.connector.kafka.PropertiesResolver#resolveSerialize

Restarts Networking. <p> This method can be called when the Networking is started for the first time. <p> But can also be called after {@link #shutdow

Restarts a job for a new execution if the cluster is stable. Otherwise, it reschedules the restart task.

Resumes WAN replication for the given {@code wanReplicationName} and {@code wanPublisherId} on this hazelcast instance. Silently skips publishers not

Instead of obtaining producerId and epoch from the transaction coordinator, re-use previously obtained ones, so that we can resume transaction after a

Retains only the {@code migrations} in the completed migration list. Acquires the partition service lock.

@return 1 if evictionPercentage is 1. 1 means we are evicting all data in record store and further retrying has no point, otherwise return {@link #EVI

{@code Serializable} variant of {@link Comparator#reverseOrder() java.util.Comparator#reverseOrder()}. @param <T> the {@link Comparable} type of elem

Returns the right-hand key extractor function.

Returns the right-hand projection function.

Starts the hazelcast console application.

Test which calls {@link TransactionalMap} methods which are expected to throw {@link QueryResultSizeExceededException}. <p/> This test fills the map t

This test calls {@link IMap} methods once which are expected to throw {@link QueryResultSizeExceededException}. <p/> This test fills the map to an amo

Runs given action. @see Runnable#run

Quick test which just calls the {@link IMap} methods once and check for the {@link QueryResultSizeExceededException}. <p> This test fills the map to a

Test which calls {@link TransactionalMap} methods which are expected to throw {@link QueryResultSizeExceededException}. <p> This test fills the map to