Returns a builder object that offers a step-by-step fluent API to build a custom JMS topic sink for the Pipeline API. See javadoc on {@link JmsSinkBui

Returns the map name in the form {@code __jet.resources.<jobId>}

Returns an immutable set of all keys in this HazelcastProperties. @return set of keys

Initiates the building of a streaming source that consumes a Kinesis data stream and emits {@code Map.Entry<String, byte[]>} items. <p> Each emitted i

Returns a consumer that will pass on to the `delegate` consumer on the last execution. It assumes that there will be {@link #LOCAL_PARALLELISM} invoca

Returns the timestamp of the last forwarded watermark for the given key. <p> If there was no watermark added, it returns {@code Long.MIN_VALUE}. Can b

Flattens a supplier of traverser into a lazy-initialized traverser. It obtains the traverser from this method's argument just once, upon the first inv

Returns the number of remaining live queues, i.e., {@link #queueCount()} minus the number of queues nulled out by calling {@link #removeQueue(int)}.

Loads the value of a given sequence. Null value means that the item was not found. This method is invoked by the ringbuffer if an item is requested wi

Task callback to initialize its inner state, after a replica promotion, from the given map. This is invoked once per task's lifecycle in a single memb

Synchronously loads the specified entries into the cache using the configured {@link javax.cache.integration.CacheLoader} for the given keys. <p> If a

Loads all the keys from the store. <p> The items identified by the keys will be loaded in the iteration order of the returned Set @return all the key

Returns the locally owned set of keys. <p> Each key in this map is owned and managed by a specific member in the cluster. <p> Note that ownership of t

Used to prevent further mutations to the DAG after submitting it for execution. <p> It's not a public API, can be removed in the future.

Primitive specialised forEach implementation. <p> NB: Renamed from forEach to avoid overloading on parameter types of lambda expression, which doesn't

Looks up the User Code Namespace name associated with the specified queue name. This starts by looking for an existing {@link QueueContainer} and chec

Creates a server instance of Hazelcast. <p> If user sets the system property "print.port", the server writes the port number of the Hazelcast instance

Returns {@link ManagedContext} associated with this job.

Transform the Iterable by applying a function to each element

@param mapFn transforms the queried document to the desired output object @param <T_NEW> type of the emitted object

Returns an {@link Iterator} over the sequence of JSON objects parsed from given {@code reader}. Each object is converted to a {@link Map}. It will thr

Mark the result as closed. Invoked when we receive an update count or the last page.

Marks the given partition as unindexed by this index. @param partitionId the ID of the partition to mark as unindexed.

Matches an index for the given attribute and match hint. @param attribute the attribute to match an index for. @param matchHint the match hint; {@lin

Merge two {@link Properties} instances into one. {@code newProperties}'s keys has priority over {@code original} keys.

Copies a block from one allocator to another, then frees the source block.

Creates a CDC source that streams change data from a MySQL database to Hazelcast Jet. <p> You can configure how the source will behave if the database