Returns the total amount of time the task spent while scheduled in. @param unit The time unit to return the duration in. @return The total amount of

Returns the TPC token associated with this endpoint, if TPC is enabled on the server-side and the client is TPC-aware. If not, {@code null} is returne

Gets the TransactionManagerService. @return the TransactionManagerService

Returns the transactional object instance with the specified name and service name. @param serviceName service name for the transactional object inst

Returns {@link TransformerFactory} with XXE protection enabled.

@return the maximum number of times the IP Datagram (ping) can be forwarded

Get the TTL in milliseconds. @return the TTL

Gets the ID that uniquely identifies the transaction. @return the transaction ID

@return size of an element of the type represented by this object @throws IllegalArgumentException if the type does not have a definite size.

Returns the uuid of the member the task is associated with. <p>The uuid will be {@code null}, if the task was scheduled to particular partition. @re

Returns the object value of the operation. @return The object value.

Overloaded version of {@link Map#get(Object)} that takes a primitive long key. Due to type erasure have to rename the method @param key for indexing

Method for attribute-specific getters that can extract from one path only

Gets the value part of the metadata @return the metadata's value

Watermark value to be saved to state snapshot for the given source partition index. The returned value should be {@link #restoreWatermark(int, long) r

Overrides the default name of the Python function that transforms Jet pipeline data. The default name is {@value PythonServiceConfig#HANDLER_FUNCTION_

Sets the name of the Python module that has the function that transforms Jet pipeline data.

Checks whether a record is expired or not. @param dataKey the record from record-store. @param now current time in millis @param backup <code>tr

Checks if the given path starts with one of the defined Hadoop prefixes: "s3a://", // Amazon S3 "hdfs://", // HDFS "wasbs://", // Azure

Hash code for multiple objects using {@link Arrays#hashCode(Object[])}.

Only gives a hint which indicates that a map-wide operation has just been executed on this partition. This method should not publish an event. <p> Cur