Logs to {@link #finest(String)} using a lazily evaluated {@code template} {@link String} with arguments, formatted using {@link String#format(String,

Overrides the default name of the stage with the name you choose and returns the stage. This can be useful for debugging purposes, to better distingui

Creates an {@code int[]} for the expected (de)serialization count parameterization. @param put expected count for the put() (de)serialization @

Returns an immutable {@link Set} clone of the mappings contained in this map. <p> <b>Warning:</b> <p> The set is <b>NOT</b> backed by the map, so chan

Returns the event key

Returns the HazelcastProperties. <p> The returned value will never change and will never be {@code null}. @return the HazelcastProperties

Get current node. <p> @return the {@link Node}

Checks if TPC is enabled. @return true if enabled, false otherwise.

Get the thread that is currently running this OperationRunner instance. <p> This value only has meaning when an Operation is running. It depends on th

@since Jet 4.4 @deprecated Use {@link HazelcastInstance#getSql()} instead.

Deserializes an object. <p> This method can safely be called on an object that is already deserialized. In that case, that instance is returned. <p> I

Clears the map and deletes the items from the backing map store. <p> The MAP_CLEARED event is fired for any registered listeners. See {@link com.hazel

{@inheritDoc} <p> <b>Warning:</b> <p> This method uses {@code hashCode} and {@code equals} of the binary form of the {@code key}, not the actual imple

@since Jet 3.0 @deprecated Use {@link HazelcastInstance#getCluster()} instead.

@param name Map name. @return Container or {@code null} if map with the given name doesn't exist.

Execute a query, assert that it returns exactly 1 row and 1 column. Assert the type of the result and optionally the result value. @param sql

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

Returns this Hazelcast instance member. <p> The returned value will never be null, but it may change when local lite member is promoted to a data memb

Called after {@link #init(Context)} to retrieve instances of {@link Processor} that will be used during the execution of the Jet job. @param count th

Writes a primitive long. @param fieldName name of the field @param value long value to be written @throws IOException in case of any exceptional

Gets the logger for a given name. <p> It is best to get an ILogger through this method instead of calling {@link com.hazelcast.logging.Logger#getLogge

Offers the supplied item to the bucket with the supplied ordinal. <p> Items offered to outbox should not be subsequently mutated because the same inst

Returns the lifecycle service for this instance. <p> LifecycleService allows you to shut down this HazelcastInstance and listen for the lifecycle even

Applies the aggregation logic on all map entries and returns the result <p> Fast-Aggregations are the successor of the Map-Reduce Aggregators. They ar

@return Current time since epoch in millis.

Creates a vertex from a {@code Supplier<Processor>} and adds it to this DAG. @param name the unique name of the vertex @param simpleSupplie

Returns the next item, removing it from this traverser. If no item is available, returns {@code null}. If this traverser is <em>null-terminated</em>,

Returns true after all the input queues are done.

Creates a new, empty pipeline. @since Jet 3.0