Tries to process the supplied watermark. The value is always greater than in a previous call with watermark with the same key. The watermark is delive

Accept visitor. Predicate can either return its own instance if no modification was done as a result of the visit. In the case there is a change neede

Adds an item to the tail of the ringbuffer. If there is no space in the ringbuffer, the add will overwrite the oldest item in the ringbuffer. The meth

Add vector collection config. @param vectorCollectionConfig the vector configuration to add @return this config instance @since 5.5

Assert that the thread eventually completes without an error.

Runs the provided {@link Callable} with the {@code Namespace} context of the {@code Namespace} context defined by the provided Namespace name if avail

Copies in order {@code sourceFirst} and {@code sourceSecond} into {@code dest}.

Creates the data structure specific {@link EventJournalTestContext} used by the event journal tests. @param <K> key type of the created {@link EventJ

@return create initial state of this operation

The id of the listener which was provided during registration.

Denotes whether register a local listener or not.

The id of the listener which was provided during registration.

Denotes whether register a local listener or not.

True if unregistered, false otherwise.

Registration id for the listener.

True if unregistered, false otherwise.

Registration id for the listener.

Ensures that the file described by the supplied parameter does not exist after the method returns. If the file didn't exist, returns silently. If the

Determines the local parallelism of the transform by looking at its preferred local parallelism, the local parallelism of its upstream transforms, and

Returns an instance of the {@link EventBuilder} interface. It can be performance optimized (e.g. when Event Audit logging is disabled). The {@link Eve

converts the {@code directory} to canonical path if it is not one of the Hadoop prefixes. see {@link FileSourceBuilder#hasHadoopPrefix(String)}

Returns the encryption algorithm. @return the encryption algorithm

Gets the auto off time duration for the diagnostics service in minutes. <p>Auto off control is disabled by default.</p> <p> <b>The auto off feature wi

@return the awsConfig join configuration

@return internally used ID for this query cache

Convert internal column type to a public type. @param columnType Internal type. @return Public type.

Returns the class name of the configured {@link EvictionPolicyComparator} implementation. @return the class name of the configured {@link EvictionPol

This ID correlates the request to responses. It should be unique to identify one message in the communication. This ID is used to track the request-re

Returns all registered data connection configurations keyed by store's name. @return registered data connection configurations keyed by store's name

@return a {@link ObjectDataInput} reading whatever was written to the test's output stream

Reads the double value from given address. @param address the address where the double value will be read from @return the double value that was read

@return set of field names on this portable class

Returns the inbound edges connected to the vertex with the given name.

@return number of successful invalidations of Near Cache entries owned by this member

Get listener service