Sets the class name of the configured {@link EvictionPolicyComparator} implementation. <p> Only one of the {@code comparator class name} and {@code co

Sets a custom defined {@link DiscoveryConfig} @param discoveryConfig configuration to set @throws java.lang.IllegalArgumentException if discoveryProv

Configures the prefix for the diagnostics file. <p> So instead of having e.g. 'diagnostics-...log' you get 'foobar-diagnostics-...log'. @since 5.6

Sets the name of the Near Cache. @param name the name of the Near Cache @return this Near Cache config instance

Used to mark the inheriting task as Namespace-aware

Sets the automatic deserialized option for the result. @param resultDeserialized true if data @return the updated InvocationBuilder. @see #isResultDe

Sets the reuse address. <p> When should setReuseAddress(true) be used? <p> When the member is shutdown, the server socket port will be in TIME_WAIT st

Set User Code Deployment configuration @param userCodeDeploymentConfig the configuration of User Code Deployment @return configured {@link com.hazelc

Sets the wait timeout in millis. @param timeout the wait timeout. @see #getWaitTimeout() for more detail.

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

Returns the number of items in this CircularQueue. @return the number of items

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

Calculates {@code a - b}, returns {@code Long.MAX_VALUE} or {@code Long.MIN_VALUE} if the result would overflow. @param a the amount @param b the val

Writes arrays as json formatted. Array itself and its items are allowed to be null.

@param booleans boolean array to be written @throws IOException in case of any exceptional case

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

Returns a supplier of processors for {@link Sinks#map(String)}.

Writes a an array of Portables. @param fieldName name of the field @param values portable array to be written @throws IOException in case of any e

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

Adds an item to this CircularQueue. @param item the item to add. @throws NullPointerException if item is null. @throws IllegalStateException when th

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

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

Adds one user to the configuration. @param password user's password @param roles roles assigned to the user @return this object

Offers a step-by-step API to build a pipeline stage that co-aggregates the data from several input stages. The current stage will be already registere

Gets a list of all aliased discovery configs from {@code config}.

Applies this function to the given arguments. @param t the first function argument @param u the second function argument @return the function result

Returns this JSON value as a <code>boolean</code> value, assuming that this value is either <code>true</code> or <code>false</code>. If this is not th

Returns an adapted W3C {@link Node} view of the provided {@link YamlNode} @param yamlNode The YAML node to adapt @return the adapted W3C Node or {@co

Runs a streaming query and checks that for a hard-coded time it doesn't return any results.

We assert eventually because waiting for safe state does not mean all partition migration events are received and processed. We should give MapMigrati

Assumes that the given {@link DataStructureAdapter} implements a specified {@link DataStructureMethods}. @param adapterClass the {@link DataStructure

Returns the first ID in the set.

Activates the {@link RoutingPolicy#BROADCAST BROADCAST} routing policy.

Calls the requested service and returns a future which will be completed with the result once a response is received.

Makes a REST call to Kubernetes API and returns the result JSON. @param urlString Kubernetes API REST endpoint @return parsed JSON @throws Kubernetes

Attempts to cancel further scheduling of this task. This attempt will fail if the task has already completed, has already been cancelled, or could no

Tests if the elements inside the argument collection are not null. If collection is null or empty the test is ignored. @param argument the iterab

Checks that the {@code object} is not null and implements {@link Serializable} and is correctly serializable by actually trying to serialize it. This

Clears a value stored at the given index in this storage. @param index the index to clear a value at. @return {@code null} if this storage array is e

Compacts or clears the buffer depending if bytes are remaining in the byte-buffer. @param bb the ByteBuffer

Note: the fact that the given value is of type Comparable doesn't mean that this value is of the same type as the one that's stored in the index, thus

Creates a new {@code MemberMap} including given members. @return a new {@code MemberMap}