Converts Data to HeapData. Useful for offheap conversion. @return the onheap representation of data. If data is null, null is returned.

Converts server's existing view of members into collection of uuid-collections based on partition grouping info. @param membersView members in the

Creates a new {@link RingbufferConfig} for a ringbuffer that will keep event journal events for a single partition. @param config the event journa

This method is called on a backup node (replica). Given all conditions are satisfied, this method initiates a replica sync operation and registers it

Tries to close the server socket and connections to other <code>HazelcastInstance</code>s. @param hazelcastInstance the Hazelcast instance to close s

Tries to create the exception with appropriate constructor in the following order. In all cases the cause is set (via constructor or via {@code initCa

Drains items from the queue until either: <ul><li> encountering an incomplete item </li><li> the outbox gets full </li></ul> @return true if

Drains items from the queue until either: <ul><li> encountering a non-completed item </li><li> the outbox gets full </li></ul> @return true i

Publishes value got from remote or deletes reserved record when remote value is {@code null}. @param key key to update in Near C

Tries to shut down <code>HazelcastInstance</code> forcefully; including closing sockets and connections, stopping threads, etc. @param hazelcastInsta

Starts the execution of the job if it is not already completed, cancelled or failed. <p> If the job is already cancelled, triggers the job completion

Return type of the DataConnection with the given name @param name name of the DataConnection @return type of the data connection

Writes a message. <p> Should only be called from the reactor-thread.

Updates the PN counter state for this replica and returns the updated value. The {@code delta} parameter must be greater than or equal to 0. The {@cod

Recalculates a new LoadStatus. Returned instance of {@link LoadImbalance} are recycled between invocations therefore they are valid for the last invoc

The query to execute for each item. It should contain a parametrized query to which the {@linkplain #bindFn(BiConsumerEx) bind function} will bind val

Specifies that Jet should use Apache Hadoop for files from the local filesystem. Otherwise, local files are read by Jet directly. One advantage of Had