Called on thread start to inject/intercept extension specific logic, like; registering thread in some service, executing a special method before threa

Called when an entry is updated. @param key the key @param oldValue the old value @param value the new value

Returns the index of the data map into which the new snapshot will be written.

Returns the ordinal value (useful for doing a switch case based on the type of CallStatus). @return the ordinal value.

@return the OS arch ("os.arch" System property).

Overrides the number of available processors returned by the method {@link #get()}. <p> This is to be used only for testing. @param availableProcesso

Parse SQL statement. @param sql SQL string. @return SQL tree.

Returns the value set by {@link #setPartitionIdleTimeout(long)}. @since Jet 3.1

Calls to this method will pause WAN event container polling. Effectively, pauses WAN replication for its {@link WanPublisher} instance. <p> WAN events

Returns the next sequence which the tail will be at after the next item is added. Please note that there is no item in the Ringbuffer with the returne

Given a number, returns that number as a percentage string. @param p the given number @return a string of the given number as a format float with two

Sets the permission required to use this sink when the security is enabled. The default value is {@code null} which means there is no restriction to u

Called when current snapshot phase 2 is done in {@link ProcessorTasklet}. All processors do it concurrently.

Cleans up (closes) the thread context which was set up by {@link #pushThreadContext()}.

Set the predicate to apply at the source. See the {@link RemoteMapSourceBuilder} for more details. @param predicate the predicate @return this builder

Prepare SQL query. @param task Optimization task containing all necessary context. @return Prepared plan.

Prepare a candidate for {@code IS (NOT) TRUE/FALSE} expression. <p> The fundamental observation is that boolean column may have only three values - TR

Populate query cache with initial set of entries as {@link Data}. Triggers an {@link EntryEventType#ADDED ADDED} event for each entry that is added to

Sets the page value to previous page.

Called to print node information during startup

Called when the pipeline needs to be processed. <p> Any exception that leads to a termination of the connection like an IOException should not be deal

Process store operations and returns failed operation per partition map. @param delayedEntries to be written to store. @return failed store operation

Processes event. @param event type of event.

Process the metadata for the job upload @param parameterObject specifies the first message for the job upload

If there are no inbound ordinals left, we will go to COMPLETE state, otherwise to PROCESS_WATERMARKS.

This method is called when a processor tasklet completes. @param lastCompletedPhase2SnapshotId the last snapshotId for which the processor did th

Create the {@link java.util.Properties} with the provided config file location. @param configFileLocation the location of the config file to configur

Metrics collection callback that is called in every metric collection cycle. The collected metrics should be passed to the {@link MetricsCollectionCon

@param targetClassLoader the classloader on which the proxy will be created @param delegate the object to be delegated to by the proxy @retur

Publishes query-cache events locally. @param mapName underlying map name of query cache @param cacheId ID of the query cache @param event

Publishes the message asynchronously to all subscribers of this topic. @param message the message to publish asynchronously to all subscribers of thi