Converts list of {@link IndexIterationPointer}s to ordered list of non-overlapping pointers. @param result List to be normalized. It may be modified

Specifies an arbitrary option for the underlying source. If you are looking for a missing option, check out the {@link FileFormat} class you're using,

Returns the guarantee for current job.

Reads one item from the ring buffer and returns the serialized format. If the item is not available, it will try and load it from the ringbuffer store

@param fieldName name of the field @return the portable array read @throws IOException in case of any exceptional case

@deprecated for the sake of better naming. Use {@link #readString()} instead

Removes a DataConnection. @param name name of the DataConnection @throws IllegalArgumentException if the DataConnection was created through config,

Removes the specified item listener. Returns silently if the specified listener was not added before. @param registrationId ID of the listener regist

Returns the name of the schema containing the record's table. Note: not all databases have the concept of a schema (for example MySQL). @return name

Sets the name for the MapStore implementation class @param className the name to set for the MapStore implementation class

Sets the correlation id of the message. This ID correlates the request to responses. @param correlationId the correlation id of the message @return th

Sets the expiration time in milliseconds. @see System#currentTimeMillis()

Set {@code true} to enable value caching, otherwise set {@code false} <p> Default value is {@value #DEFAULT_INCLUDE_VALUE}. @param includeValue Set {

Sets the {@link LoadBalancer}. <p> If a load balancer class name was set, it will be removed. @param loadBalancer {@link LoadBalancer} @return config

Sets the metric of this vector index configuration. @param metric the metric to set @return this VectorIndexConfig instance

Overrides the public address of a member. Behind a NAT, two endpoints may not be able to see/access each other. If both nodes set their public address

Configures the split brain protection feature. When enabled, Jet will restart the job after a topology change only if the cluster quorum is satisfied.

Sets type of the index. <p> Defaults to {@link IndexType#SORTED}. @param type Type of the index. @return This instance for chaining.

Sets the type of the class that will be serialized via this implementation. @param typeClass type of the class that will be serialized via this imple

Returns the state of the Reactor. <p/> This method is thread-safe. @return the state.

Returns the total number of total operations @return number of total operations

Translates the given address to another address specific to network or service @param address to be translated @return new address if given address i

Tries to update reserved key with supplied value. If update happens, value is published. Publishing means making the value readable to all threads. If

Try to remove the registry entry for given instance uuid and primary address. To make sure not delete a new entry of a rejoined member with the same u

Applies the specified delta configuration to a {@link #suspend() suspended} job and returns the updated configuration. @throws IllegalStateException

Excludes the given targets for this metric. <p> Note1: Calling this method overwrites the previously set excluded targets Note2: The excluded targets

@param values float array to be written @throws IOException in case of any exceptional case

Adds the client config to the end of the alternative client configurations list. @param clientConfig the ClientConfig to add @return this for chainin

Adds the list configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtained in

@param listener The listener to be registered. @return The registration ID

Returns a copy of this aggregate operation, but with the {@code export} and {@code finish} primitives composed with the supplied {@code thenFn}. This

Applies this predicate to the given map entry. <p> Implementations <i>must</i> be thread-safe, since this method may be called by multiple threads con

Returns the number of contributing streams this operation is set up to handle. The index passed to {@link #accumulateFn(int)} must be less than this n

@see org.assertj.core.api.AbstractCharSequenceAssert#startsWith(CharSequence)

Computes capacity delta for sorted short arrays.

Tests if the newBackupCount count is valid. @param newBackupCount the number of sync backups @param currentAsyncBackupCount the current numb

Tests whether the supplied object is an instance of the supplied class type. @param type the expected type. @param object the object te

Tests if the {@code value} is &gt;= 0. @param value the value tested to see if it is not negative. @param paramName the the name of the checked

Calls WindowUtils.addWindowBounds with a record with the given {@code timestamp} and window policy. Asserts that the returned traverser contains the g

Obtains a {@link NodeEngine} reference from {@link NodeEngineThreadLocalContext} and uses it to call {@link UserCodeNamespaceService#cleanupNamespace(

Removes all the elements in this {@link WriteBehindQueue} Queue will be empty after this method returns.

{@code Serializable} variant of {@link Comparator#comparingInt(ToIntFunction) java.util.Comparator#comparingInt(ToIntFunction)}. @param <T> the type

Converts a list of {@link HazelcastRexNode}. See also {@link #convertFilter(HazelcastRexNode)} for information about {@link RexInputRef} conversion.