Sets the cluster name uniquely identifying the hazelcast cluster. This name is used in different scenarios, such as identifying cluster for WAN publis

Increments the counter by one. @return the new counter state

Returns the Jet config

Removes {@code key} if present. @param key non-null key of the key-value entry to remove @return null if {@code key} was not present, otherwise the va

Presents a parsed form of the underlying JSON message as a {@code Map}. The keys are the top-level fields from the JSON and the values can range from

Returns the underlying Hazelcast instance used by Jet. It will be either a server node or a client, depending on the type of this {@code JetInstance}.

Creates a {@link LongGauge} for a given metric name. If no gauge exists for the name, it will be created but no probe is set. The reason to do so is

Sets the current value of the counter.

Returns the number of partitions. @return the number of partitions

Returns the current status of this job. Each invocation queries the status from the job coordinator. For light jobs it returns only {@link JobStatus#R

Like a String.indexOf but without MIN_SUPPLEMENTARY_CODE_POINT handling @param input to check the indexOf on @param ch character to find the ind

Publishes the message to all subscribers of this topic. @param message the message to publish to all subscribers of this topic @throws TopicOverloadE

Removes the mapping for the key from this map if it is present. <p> Unlike {@link #remove(Object)}, this operation does not return the removed value,

Sets the expected output and runs the test. <p> The {@code expectedOutput} can contain {@link com.hazelcast.jet.core.Watermark}s. Each Watermark in th

Returns a string that identifies the {@link FileFormat} supported by this function provider.

Returns the value of the field 0.

Indicates that node is not shutting down or it has not already shut down @return {@code true} if node is not shutting down or it has not already shut

Checks if statistics are enabled for this map. @return {@code true} if statistics are enabled, {@code false} otherwise

Sets the prefix of the descriptor's metric. @param prefix The prefix to set @return the descriptor instance @see MetricDescriptor#prefix()

Returns the partition ID. <p> The partition ID will be between 0 and partitionCount (exclusive). @return the ID of the partition

Returns a sink that adds the items it receives to a Hazelcast {@code IList} with the specified name. <p> No state is saved to snapshot for this sink.

@return true if the underlying object exists as determined by the exists function passed to this object during construction

@return the converter associated with this index; or {@code null} if the converter is not known because there were no saves to this index and the attr

Returns the current Hazelcast instance. @since 5.0

Creates a table with single column named "v" with INT type. The rows contain the sequence {@code 0 .. itemCount}.

Returns the value of the field 1.

Returns a traverser that will emit the same items as this traverser, but only those that pass the given predicate.

Gets the current value of the counter. @return the current value of the counter.

Tests if a {@code value} is positive, that is strictly larger than 0 (value &gt; 0). @param paramName the name of the checked parameter that will be

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

Returns underlying {@code NodeEngine} for this node. @return underlying {@code NodeEngine} for this node.

Behaviour of this method varies for {@link RoutingMode#SINGLE_MEMBER}, {@link RoutingMode#MULTI_MEMBER}, and {@link RoutingMode#ALL_MEMBERS} routing c

Returns byte array representation of internal binary format. @return binary data

Declares that the source will not assign any timestamp to the events it emits. You can add them later using {@link GeneralStage#addTimestamps(ToLongFu

Converts a {@code long} job or execution ID to a string representation. Currently, it is an unsigned 16-digit hex number.

Creates and executes a one-shot action that becomes enabled after the given delay. @param command the task to execute @param delay the time from now

Sets the size which is used by the {@link MaxSizePolicy}. <p> The interpretation of the value depends on the configured {@link MaxSizePolicy}. <p> Acc

Returns the number of elements in this collection. If this collection contains more than <code>Integer.MAX_VALUE</code> elements, returns <code>Integ

Creates a new HazelcastInstance (a new client in a cluster). This method allows you to create and run multiple instances of Hazelcast clients on the s

Creates a {@link Table} object with the given fields. Should return quickly; specifically it should not attempt to connect to the remote service. <p>

Unlock a specific key. @param key the locked key @param caller the identifier for the caller @param threadId the identifier for the t

Set the {@link ProcessingGuarantee processing guarantee} for the job. When the processing guarantee is set to <i>at-least-once</i> or <i>exactly-once<

Returns true if this member is a lite member. @return <code>true</code> if this member is a lite member, <code>false</code> otherwise. Lite members d

Quote individual parts of a compound identifier and concat with `.` delimiter

Traverses the DOM and fills the config @param rootNode the root node @throws Exception in case of any exceptional case

Returns the partition ID of the given item. @param partitionCount the total number of partitions in use by the underlying Hazelcast instance

Checks if a string is empty or not after trim operation @param s the string to check. @return true if the string is {@code null} or empty, false othe

Sends a single request line to the server. Adds CRLF at the end and flushes. @param line line to send

Applies the user defined {@code EntryProcessor} to the entry mapped by the {@code key}. Returns the object which is the result of the {@link EntryProc

Connection Retry Config is controls the period among the retries and when should a client gave up retrying. Exponential behaviour can be chosen or jit

Returns number of hits of the entry. <p> <b>Warning:</b> This method returns {@code -1} if statistics are not enabled or not implemented. @return num

Lock a specific key. @param key the key to lock @param caller the identifier for the caller @param threadId the identifier for the th

Creates a new instance of class with {@code className}, using the no-arg constructor. Preferably uses the class loader specified in {@code classLoader

Receives a response line from the server

@return the value stored inside this storage at the given index or {@code null} if nothing stored at it.

Returns the total number of queries performed on the map. <p> The returned value includes queries processed with and without indexes. @see #getIndexe

Sets the metric field of the descriptor. @param metric The metric to set @return the descriptor instance @see MetricDescriptor#metric()

This method executes the normal assertEquals with expected and actual values. In addition, it formats the given string with those values to provide a

Returns the context table. It is:<ul> <li>for scans, it's the scanned table <li>for DML, it's the target table <li>for nested loop reader, it's the ta

Asynchronously puts the given key and value. {@link CompletionStage} can be converted to a {@link java.util.concurrent.CompletableFuture} to obtain th

Accumulates the given entries. @param input input to accumulate.