Establish this tenant's thread-local context. The tenant control implementation can control the details of what kind of context to set and how to esta

@return current record after put.

Puts the given job record into the jobRecords map. If another job record is already put, it checks if it has the same DAG. If it has a different DAG,

Returns the number of {@link Reactor} instances in this TpcEngine. <p/> This method is thread-safe. @return the number of reactor instances.

Returns the type of {@link Reactor} used by this TpcEngine. <p/> This method is thread-safe. @return the type of Reactor.

Reads an array of dates consisting of year, month, and day. @param fieldName name of the field. @return the value of the field. The items in the arra

Reads an array of arbitrary precision and scale floating point numbers. @param fieldName name of the field. @return the value of the field. @throws H

Reads an array of times consisting of hour, minute, second, and nanoseconds @param fieldName name of the field. @return the value of the field. The i

Reads an array of timestamps consisting of date and time. @param fieldName name of the field. @return the value of the field. The items in the array

Reads an array of timestamps with timezone consisting of date, time and timezone offset. @param fieldName name of the field. @return the value of the

Returns a supplier of processors for {@link Sources#cache(String)}.

Reads fields from the input stream @param in input @throws IOException if an I/O error occurs. In particular, an <code>IOExceptio

Reads an array of Date's to LocalDate[] @param fieldName name of the field @return the LocalDate array read @throws IOException in case of any except

Reads an array of Decimal's to BigDecimal[] @param fieldName name of the field @return the BigDecimal array read @throws IOException in case of any e

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

Returns a supplier of processors for {@link HadoopSources#inputFormat(Configuration, BiFunctionEx)}.

GET StatefulSets list and update the latest runtime context.

Returns a supplier of processors for {@link Sources#list(String)}.

Reads a collection from the given {@link ObjectDataInput}. It is expected that the next int read from the data input is the collection's size, then th

Create a ProcessorSupplier for a remote map in another cluster

Reads an array of Time's to LocalTime[] @param fieldName name of the field @return the LocalTime array read @throws IOException in case of any except

Reads an array of Timestamp's to LocalDateTime[] @param fieldName name of the field @return the LocalDateTime array read @throws IOException in case

Reads an array of TimestampWithTimezone's to OffsetDateTime[] @param fieldName name of the field @return the OffsetDateTime array read @throws IOExce

Accepts the base address and size of a previously allocated block and "reallocates" it by either: <ol><li> Resizing the existing block, if possibl

Sets the function Jet will call upon receiving every item. The function receives two arguments: the state object (as provided by the {@link #createFn}

Re-inserts the given descriptor into the pool. @param descriptor The descriptor to re-insert

Returns an aggregate operation that constructs the result through the process of <em>immutable reduction</em>: <ol> <li>The initial accumulated va

Registers all the metrics in this metric pack. @param metricsRegistry the MetricsRegistry upon which the metrics are registered.

Registers all the metrics in this metric pack. @param metricsRegistry the MetricsRegistry upon which the metrics are registered.

Registers all the metrics in this metrics pack. @param metricsRegistry the MetricsRegistry upon which the metrics are registered.

Registers all the metrics in this metric pack. @param metricsRegistry the MetricsRegistry upon which the metrics are registered.

Registers all the metrics in this metrics pack. @param metricsRegistry the MetricsRegister upon which the metrics are registered.

Registers all the metrics in this metrics pack. @param metricsRegistry the MetricsRegistry upon which the metrics are registered.

Releases all reserved capacity info on this counter.

Get the remembered value. Returns {@code null} if value was never asked for

Removes {@link AccumulatorInfo} from this supplier. @param mapName map name. @param cacheId cache name.

{@inheritDoc}

records of keys will be deleted one by one and will publish a REMOVE event for each key. @param keys set of keys to be cleaned.

Removes the counter for the given {@code serviceName} and {@code dataStructureName}.

@param id registration ID of destroy action @return true if remove is successful

Removes an endpoint from this ClientEndpointManager. Closes associated connection and runs all registered destroy actions to endpoint. No action take

Removes an entry from this indexes instance identified by the given key and value. <p> Consider using {@link #removeEntry(CachedQueryEntry, Index.Oper