A facade that hides the details of Hazelcast partitioning SPI and exposes just the partitioning strategy.
A subset of
Queue<Object> API restricted to the consumer side,
with additional support for bulk draining operations.
Description of the cause that has led to the job being suspended.
Data sink for a
Encapsulates the logic associated with a
DAG edge that decides
on the partition ID of an item traveling over it.
When Jet executes a DAG, it creates one or more instances of
Processor on each cluster member to do the work of a given vertex.
Context passed to the processor in the
Context passed to the meta-supplier at init time on the member that received a job request from the client.
Context passed to the supplier in the
This object tracks and determines the current
Watermark given the
event timestamps as they occur for a single input stream.
Base class to implement custom processors.
A traverser with an internal
Marks a key in the snapshot state to indicate that the corresponding entry should be broadcast to all processors when restoring the snapshot.
Describes a computation to be performed by the Jet computation engine.
A utility that helps a source emit events according to a given
A holder of functions and parameters Jet needs to handle event time and the associated watermarks.
A Java Service Provider hook for Hazelcast's Identified Data Serializable mechanism.
Partitioner which applies the default Hazelcast partitioning strategy.
A meta-supplier that will only use the given
on a node with given
Traverses over a single item which can be set from the outside, by using this traverser as a
Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.
Represents a unit of data processing in a Jet computation job.
Watermark is an item occasionally inserted into a disordered (sub)stream of timestamped items.
An edge describes a connection from many upstream processors to many downstream processors.
Represents current status of the job from the perspective of the job coordinator.
Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp.
Thrown when a job could not be found on the master node
Thrown when a topology change causes a job to abort.
Copyright © 2022 Hazelcast, Inc.. All rights reserved.