Unblocks incoming messages to client from given instance

Chooses the {@link RoutingPolicy#UNICAST UNICAST} routing policy for this edge. This policy is the default.

For nullable types, i.e. {@code [aType, null]}, returns {@code aType}. Otherwise, returns the specified type as-is.

See {@link InternalIndex#validatePartitionStamp(long)}.

Returns a list of the values in this array in document order. The returned list is backed by this array and will reflect subsequent changes. It cannot

Returns a copy of the DAG's vertices. Adding a vertex to or removing a vertex from the returned {@link Set} will not be reflected in the DAG, and vice

If skipped, or passed {@code null}, {@linkplain #nextAddress() the next address} is used.

This test case is expected to fail if the source is any of literal, column or dynamic parameter.

Selects a type having a higher precedence from the two given types. <p> Type precedence is used to determine resulting types of operators and to assig

Writes an array of booleans. @param fieldName name of the field. @param value to be written.

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

Writes a nullable array of nullable booleans. @param fieldName name of the field. @param value to be written.

Writes a nullable array of nullable 32-bit IEEE 754 floating point numbers. @param fieldName name of the field. @param value to be written.

Writes a nullable array of nullable 64-bit IEEE 754 floating point numbers. @param fieldName name of the field. @param value to be written.

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

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

Writes a 32-bit IEEE 754 floating point number. @param fieldName name of the field. @param value to be written.

Writes a 64-bit IEEE 754 floating point number. @param fieldName name of the field. @param value to be written.

Returns a meta-supplier of processors for a sink vertex that logs all the data items it receives. The log category is {@code com.hazelcast.jet.impl.co

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

A primitive that updates the accumulator state to account for a new item coming from stream-1. <p> The consumer must be stateless and {@linkplain Proc

Adds the given value to the current value. @param delta the value to add @return the updated value @throws NoDataMemberInClusterException if the clus

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

Registers the class to be serialized with Compact serialization. <p> For the given class, Compact serialization will be used instead of Portable, Iden

Adds the migration to the set of completed migrations and increases the completed migration counter. Acquires the partition service lock to update the

Adds an array of Date's to the class definition @param fieldName name of the field that will be added to this class definition @return itself for cha

Adds an array of Decimal's to the class definition @param fieldName name of the field that will be added to this class definition @return itself for

Adds the device configuration. Removes the default device config if present. @param deviceConfig device config @return this config instance

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

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

Inserts to the end of this queue. @param e element to be offered @param addWithoutCapacityCheck if set to {@code true},

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

Helper method to add a new {@link ProxyFactoryConfig} @param proxyFactoryConfig {@link ProxyFactoryConfig} @return configured {@link com.hazelcast.cl

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

Adds an array of Time's to the class definition @param fieldName name of the field that will be added to this class definition @return itself for cha

Adds an array of Timestamp's to the class definition @param fieldName name of the field that will be added to this class definition @return itself fo

Adds an array of TimestampWithTimezone's to the class definition @param fieldName name of the field that will be added to this class definition @retu

Adds trusted interface (i.e. source IP address or expression). @param ip IP address to be added. @return configuration object itself

Called after node is started

Returns a supplier of processors for a vertex that performs a general group-by-key-and-window operation and applies the provided aggregate operation o

Returns a supplier of processors for a vertex that groups items by key and performs the provided aggregate operation on each group. After exhausting a

Returns a supplier of processors for a vertex that performs the provided aggregate operation on all the items it receives. After exhausting all its in

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

Checks whether all aliased discovery configs have the tag {@literal <use-public-ip>true</use-public-ip}. <p> Note that if no config is enabled, then t