Calculates the entry size of this store which reflects the partition size of the cache. @return partition size of the cache.

Returns a JsonValue instance that represents the given <code>int</code> value. @param value the value to get a JSON representation for @retu

Accept a visitor to this physical rel. @param visitor Visitor. @return the DAG vertex created for this rel

Returns the member that fired this event. @return the member that fired this event.

Returns {@code true} if the given collection is not {@code null} and not empty, otherwise returns {@code false}. @param collection the given collecti

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

Allocates a block of addresses with the requested size and returns the base address of the block. The contents of the block will be initialized to the

Checks the lock for the specified key. <p> If the lock is acquired then returns true, else returns false. <p> <b>Warning:</b> <p> This method uses {@c

Returns the name of this transformation.

Factory method that wraps the given {@code ProcessorSupplier} and returns the same instance for each given {@code Address}. @param preferredLocalPara

Connects the channel. <p> This call should only be made once and is not thread-safe. <p> This call blocks until: <ol> <li>the connect succeeds</li> <l

Returns a snapshot of the current values of all job-specific metrics. Not supported for light jobs. <p> While the job is running the metric values are

Utility method that creates an {@link java.util.HashSet} with its initialCapacity calculated to minimize rehash operations

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

Get metrics registry. <p> @return the {@link MetricsRegistry}

Resolves the final field list given an initial field list and options from the user. Jet calls this method when processing a CREATE MAPPING statement.

Tests if a string contains text. @param argument the string tested to see if it contains text. @param errorMessage the errorMessage @return the s

Combines the given result with this result modifying this result. @param result the result to combine with. @see #onCombineFinished()

Returns all submitted jobs. The result includes completed normal jobs, but doesn't include completed {@linkplain #newLightJob(Pipeline) light jobs} -

Returns the service name on which this event occurred. @return the service name on which this event occurred. @see com.hazelcast.map.impl.MapService#

Returns true if this member is the local member. @return <code>true</code> if this member is the local member, <code>false</code> otherwise.

Asynchronously puts the given key and value. The entry lives forever. Similar to the put operation except that set doesn't return the old value, which

Sets the {@link MergePolicyConfig} for the data structure. @return this configuration

Sets the snapshot interval in milliseconds &mdash; the interval between the completion of the previous snapshot and the start of a new one. Must be se

Verifies this JoinConfig is valid. At most a single joiner should be active. @throws InvalidConfigurationException when the join config is not valid

Tests if the {@code value} is &gt;= 0. @param value the value tested to see if it is not negative. @param errorMessage the errorMessage @retur

Returns an aggregate operation that counts the items it observes. The result is of type {@code long}. <p> This sample takes a stream of words and find

The main entry point to the Unified File Connector. <p> Returns a {@link FileSourceBuilder} configured with default values, see its documentation for

Executes an operation remotely. <p> It isn't allowed @param op the operation to send and execute. @param target the address of that target member

Adds entries from the given {@code entryIterator}. For each entry that is successfully added, the given {@code postProcessor} is invoked with the adde

Signals the Handler that socket should be closed. @param reason the reason (can be null). @param cause the cause (can be null).

@return config for managing how the client routes to members of the cluster.

Returns the kind of the field for the given field name. <p> If the field with the given name does not exist, {@link FieldKind#NOT_AVAILABLE} is return

Returns a collection of the members that satisfy the given {@link MemberSelector}. @param selector {@link MemberSelector} instance to filter members

Returns the name of the distributed data structure which this operation operates on.

Returns the {@code value} corresponding to {@code key} in the {@code map}. If {@code key} is not mapped in {@code map}, then a {@code value} is comput

Creates a new MwCounter with 0 as its initial value. @return the new MwCounter, set to 0.

Creates a vertex from a {@code Supplier<Processor>} and adds it to this DAG. The vertex will be given a unique name created from the {@code namePrefix

Returns the tag constant {@link #TAG_0}.

Adds a field to the schema.

Obtains items from the traverser and offers them to the outbox's buckets identified in the supplied array. If the outbox refuses an item, it backs off

Releases a permit and increases the number of available permits by one. If some threads in the cluster are blocked for acquiring a permit, one of them

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

Returns the value of the member with the specified name in this object. If this object contains multiple members with the given name, this method will

Gets the call ID of this operation. The call ID is used to associate the invocation of an operation on a remote system with the response from the exec

Returns the {@link MaxSizePolicy} of this eviction configuration. @return the {@link MaxSizePolicy} of this eviction configuration

Name of the publisher, only used for debugging purposes.