Returns subtraction between given String arrays. @param arr1 first array @param arr2 second array @return arr1 without values which are not present i

Initiate wan sync for all maps. NOTE: not supported on OS, only on EE @param wanReplicationName the name of the wan replication config @param wanPubl

Initiate wan sync for a specific map. NOTE: not supported on OS, only on EE @param wanReplicationName the name of the wan replication config @param w

Returns an XML tag (e.g. {@literal <gcp>}) for the given config.

Takes an BufferObjectDataOutput from the pool. @return the taken BufferObjectDataOutput.

Returns a traverser that will emit a prefix of the original traverser, up to the item for which the predicate fails (exclusive).

Convert time to milliseconds based on the given time unit. If time unit is null, then input time is treated as milliseconds. @param time The inpu

Returns a fluent-API builder with which you can create an {@linkplain StreamSource unbounded stream source} for a Jet pipeline. It will use {@linkplai

Returns an aggregate operation that accumulates the items into a {@code Collection}. It creates empty, mutable collections as needed by calling the pr

Returns a DOT format (graphviz) representation of the Pipeline.

Converts a {@link Collection} of {@link Integer} to a primitive {@code int[]} array. @param collection the given collection @return a primitive int[]

Returns unaltered string that was used to create this object. @return original string

Set the function to extract a value from the incoming items. The value will be put into the IMap under key extracted using {@link #toKeyFn}. <p> Only

A username to authenticate

Returns a copy of this aggregate operation, but with the {@code accumulate} primitive replaced with one that expects to find accumulator objects in th

Returns a copy of this {@code ServiceFactory} with the given {@code createService} function. <p> Jet calls this function to create each parallel insta

Calls {@code callable.call()} until it does not throw an exception (but no more than {@code retries} times).

Add a valid transition from one state to one or more states

Writes an array of 16-bit two's complement signed integers. @param fieldName name of the field. @param value to be written.

Writes a nullable array of nullable 32-bit two's complement signed integers. @param fieldName name of the field. @param value to be written.

Writes an 8-bit two's complement signed integer. @param fieldName name of the field. @param value to be written.

Writes a nullable 16-bit two's complement signed integer. @param fieldName name of the field. @param value to be written.

Resets this traverser so that the following {@code next()} call will return the item supplied here. If the traverser already has an item, it is illega

Accept visitor by all predicates. It treats the input array as immutable. It's Copy-On-Write: If at least one predicate returns a different instance

@param fieldName name of the field that will be added to this class definition @return itself for chaining @throws HazelcastSerializationException if

@param factoryId factory ID of portableFactory to be registered @param portableFactory portableFactory object to be registered @return configure

Increments the remove time accumulator. @param duration the time taken in nanoseconds.

Associates the given listener to this job. The listener is automatically removed after a {@linkplain JobStatus#isTerminal terminal event}. @return Th

Adjust row count based on filter selectivity. @param rowCount Row count. @param selectivity Selectivity. @return New row count.

Returns an aggregate operation that is a composite of three independent aggregate operations, each one accepting its own input. You need this kind of

Check if all futures are done @param futures the list of futures @return {@code true} if all futures are done

Exception-declaring version of {@link Function#apply}. @throws Exception in case of any exceptional case

Adapts an int array to an Integer {@link List}. <p> The returned list is not serializable. If serializability is required, use {@code Arrays.stream(ar