Starts the map loader if there is a configured and enabled {@link MapLoader} and the key loading has not already been started. The loading may start a

Called when {@link StoreSnapshotTasklet} is done (received DONE_ITEM from all its processors). @param lastCompletedSnapshotId id of the last snapshot

Subscribe to the event journal for this reader and a specific partition ID. The method will return the newest and oldest event journal sequence. @par

Use {@link KafkaProcessors#writeKafkaP(Properties, FunctionEx, boolean)}

{@code Serializable} variant of {@link Comparator#thenComparing(Comparator) java.util.Comparator#thenComparing(Comparator)}.

Transforms the provided map of name/value pairs into a {@link JsonObject}. @param map map of JSON name-value pairs @return the JSON object

Tokenizes a version string and returns the tokens with the following grouping: (1) major version, eg "3" (2) minor version, eg "8" (3) patch version p

Returns an adapter from {@code Iterator} to {@code Traverser}. The iterator must return non-{@code null} items. Each time its {@code next()} method is

Waits for some time and rerun the {@link ControlTask}.

Tries to acquire requested permits. Less than requested permits may be acquired, if insufficient permits are available. Number of actually acquired pe

Advances the iterator to the next available record. <p> If the method has returned {@code true}, the key and the value could be accessed through {@lin

Try to remove and close/shutdown job classloader and any processor classloaders for given job <p> We keep track of phases where the classloader is use

Removes an address from the blacklist if it is temporarily blacklisted. This method has no effect if given address is not blacklisted. Permanent black

Updates the configuration with the given configuration. Updating means dynamically changing all the differences dynamically changeable. @param newCon

Set the function to update the value in Hazelcast IMap. <p> For each item it receives, it applies {@link #toKeyFn} to get the key and then applies {@l

Checks if this configuration object is in coherent state - has all required properties set.

Casts a vote for given list node. This vote is added to the item's weight.

Drops all backup operations originating from given instance. Allows waiting for first dropped backup. @param from source instance (partition owner) @

Duration in milliseconds corresponding to number of potentially lost/delayed heartbeats that will be accepted before considering it to be an anomaly.

Specifies how initial reads of the shards should be done (see <em>shardIteratorType</em> for available options). Initial read means the moment when a

Queues the {@link OutboundFrame} to be written at some point in the future. No guarantee is made that the frame actually is going to be written or rec