Returns the UUID of this member. @return the UUID of this member.

@param fieldName name of the field @return the byte value read @throws IOException in case of any exceptional case

Rollback of the current transaction. @throws IllegalStateException if there is no active transaction.

Sets the {@link TransactionType}. <p> A local transaction is less safe than a two phase transaction; when a member fails during the commit of a local

Tries to acquire the lock for the specified key. <p> If the lock is not available then the current thread doesn't wait and returns false immediately.

Sets the unit of the descriptor. @param unit The unit to set @return the descriptor instance @see interface for describing a metric#unit()

Adds a {@link MapListener} for this map. To receive an event, you should implement a corresponding {@link MapListener} sub-interface for that event. <

Execute a query and wait until it completes. Assert that the returned rows contain the expected rows, in the given order. @param sql The que

Returns the total number of indexed queries performed on the map. <p> The returned value includes only queries processed using indexes. If there are n

@return {@code true} if search results should include the user-supplied value or {@code false} if only keys should be returned.

Copies all of the entries from the given map to the cache using a custom {@link javax.cache.expiry.ExpiryPolicy}. <p> Puts of single entries happen at

Returns the total number of pending operations. This method is thread safe. This method returns a best effort value and should only be used for moni

Adds the given window definition to this stage, as the first step in the construction of a pipeline stage that performs windowed aggregation. @see Wi

Check object equality with additional hash code check. @param first First object. @param second Second object. @param expected Expected result.

Returns the {@link DAG} that's being created.

Returns the currently defined {@link DiscoveryConfig} @return current DiscoveryProvidersConfig instance

Returns the target {@link Predicate}.

Return a logger for the processor

Callback is called after all metrics are published for a given metric collection round.

Returns a predicate that always evaluates to {@code false}. @param <T> the type of the input to the predicate

Sends closing signal to the logger.

Gets the future associated with the job. The returned future is not cancellable. To cancel the job, the {@link #cancel()} method should be used. @thr

Returns the last time the value was updated. <p> <b>Warning:</b> This method returns {@code -1} if statistics are not enabled or not implemented. @re

Returns the maximum number of seconds for each entry to stay in the map. @return the maximum number of seconds for each entry to stay in the map

Gets the value of the cache entry. @return the value of the cache entry

Returns an aggregate operation that accumulates the items into a {@code HashMap} where the key is the result of applying {@code keyFn} and the value i

{@inheritDoc} <p> </p> <p> If the supplied {@code remappingFunction} is a lambda, anonymous class or an inner class, it would be executed loc

Encloses an identifier in quotation marks appropriate for the {@link CalciteSqlDialect SQL dialect}, writing the result to a {@link StringBuilder}. Wr

Sets the destination vertex of this edge, with ordinal 0.

Returns a traverser over the supplied arguments (or item array). Null items are skipped. @param items the items to traverse over @param <T> type of t

HC specific settings, operands etc. use this method. Creates an uppercase string from the given string. @param s the given string @return an uppercas

Returns the value of the field 2.

Returns the partition replica assigned to the replica index. <p> The owner has replica index 0. <p> The returned value could be {@code null} if the ow

Returns whether this member joined to a cluster. @return {@code true} if this member is joined to a cluster, {@code false} otherwise

Submits a new light job with a default config. See {@link #newLightJob(Pipeline, JobConfig)}.

Static factory to retrieve a type 4 (pseudo randomly generated) UUID based string. <p> The {@code UUID} string is generated using a cryptographically

Gracefully stops the current execution and schedules a new execution with the current member list of the Jet cluster. Can be called to manually make u

Stops the Server, releases its resources, stops threads, etc. When stopped, is can be started again by calling {@link #start()}. <p> This method has n

Validates that a key is not null. @param key the key to be validated. @param <K> the type of key. @throws java.lang.NullPointerException if provided

Tests if an argument is not null. @param argument the argument tested to see if it is not null. @param name the name of the variable/field that c

Atomically decrements the current value by one. @return the updated value, the current value decremented by one

Returns the Address of this Member. @return the address. @since 3.6

Returns the CacheSimpleConfig for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configura

Returns the device capacity.

Returns the expiration time of the entry. @return the expiration time of the entry

Checks if the Connection is alive. @return true if alive, false otherwise.

Configures the {@link EvictionConfig} of the given {@link NearCacheConfig}. @param nearCacheConfig the {@link NearCacheConfig} to configure @param ev

Synonym for {@link FunctionEx#identity}, to be used as a projection function (e.g., key extractor). @param <T> the type of the input and output object