Return whether the reads for the specific key should be blocked (see {@link #txnLock(Data, UUID, long, long, long, boolean)}). @param key the lock ke

Returns {@code true} if the operation allows checking for split brain protection, {@code false} if the split brain protection check does not apply to

Returns <code>true</code> if eviction is allowed on this record-store, otherwise <code>false</code> @return <code>true</code> if eviction is allowed

Returns {@code true} if the configuration for failing on an indeterminate operation state is enabled, {@code false} otherwise.

Shutdown the provided client and remove it from the managed list @param instance the hazelcast client instance

Gracefully shuts down HazelcastInstance. It's different from {@link #terminate()} in that it waits for partition operations to complete.

Releases internal resources solely managed by Hazelcast. This method is called when MapService is shutting down.

Shuts down this scheduler.

Shuts down a {@link ManagedChannel} <p> Tries orderly shutdown first {@link ManagedChannel#shutdown()}, then forceful shutdown {@link ManagedChannel#s

Print every value on a separate line. Use tabs (<code>\t</code>) for indentation. @return A PrettyPrint instance for wrapped mode with tab indentatio

Convenience for {@code inbox.queue().size()}

Returns true, if snapshots will be saved for this job.

Returns a supplier of processors for a vertex that sorts its input using a {@link PriorityQueue} and emits it in the {@code complete} phase. <p> The o

Internal method called to initialize the service.

Specifies time from which MongoDB's events will be read. <p> It is <strong>highly</strong> suggested to provide this argument, as it will reduce readi

Starts a Hazelcast instance with a {@link SimpleInterceptor}. @param nodeFactory use this to create the instance @return the started instance

Stores one item with its corresponding sequence. <p> Exceptions thrown by this method prevent {@link com.hazelcast.ringbuffer.Ringbuffer} from adding

Stores multiple entries. Implementation of this method can optimize the store operation by storing all entries in one database connection for instance

Stores the keys of the Near Cache.

Returns a supplier of processors for {@link Sources#filesBuilder}. See {@link FileSourceBuilder#buildWatcher} for more details.

Subtracts the given value from the current value. @param delta the value to subtract @return the updated value @throws NoDataMemberInClusterException

The {@link ResettableSingletonTraverser} is passed as a first argument to {@code callAsyncFn}, it can be used if needed.

The {@link ResettableSingletonTraverser} is passed as a first argument to {@code flatMapFn}, it can be used if needed.

Private API. Use {@link SinkProcessors#writeJmsQueueP} or {@link SinkProcessors#writeJmsTopicP} instead