Package com.hazelcast.jet.core

Jet's Core API.

Since:

Jet 3.0

Interface Summary

Interface	Description
DefaultPartitionStrategy	A facade that hides the details of Hazelcast partitioning SPI and exposes just the partitioning strategy.
Inbox	A subset of Queue<Object> API restricted to the consumer side, with additional support for bulk draining operations.
JobSuspensionCause	Description of the cause that has led to the job being suspended.
Outbox	Data sink for a Processor.
Partitioner<T>	Encapsulates the logic associated with a DAG edge that decides on the partition ID of an item traveling over it.
Processor	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.
Processor.Context	Context passed to the processor in the init() call.
ProcessorMetaSupplier	Factory of ProcessorSupplier instances.
ProcessorMetaSupplier.Context	Context passed to the meta-supplier at init time on the member that received a job request from the client.
ProcessorSupplier	Factory of Processor instances.
ProcessorSupplier.Context	Context passed to the supplier in the init() call.
WatermarkPolicy	This object tracks and determines the current Watermark given the event timestamps as they occur for a single input stream.

Class Summary

Class	Description
AbstractProcessor	Base class to implement custom processors.
AppendableTraverser<T>	A traverser with an internal ArrayDeque.
BroadcastKey<K>	Marks a key in the snapshot state to indicate that the corresponding entry should be broadcast to all processors when restoring the snapshot.
DAG	Describes a computation to be performed by the Jet computation engine.
Edge	Represents an edge between two vertices in a DAG.
EventTimeMapper<T>	A utility that helps a source emit events according to a given EventTimePolicy.
EventTimePolicy<T>	A holder of functions and parameters Jet needs to handle event time and the associated watermarks.
JetDataSerializerHook	A Java Service Provider hook for Hazelcast's Identified Data Serializable mechanism.
Partitioner.Default	Partitioner which applies the default Hazelcast partitioning strategy.
ProcessorMetaSupplier.ExpectNothingProcessorSupplier
ProcessorMetaSupplier.RandomMemberPms
ProcessorMetaSupplier.SpecificMemberPms	A meta-supplier that will only use the given ProcessorSupplier on a node with given Address.
ResettableSingletonTraverser<T>	Traverses over a single item which can be set from the outside, by using this traverser as a Consumer<T>.
SlidingWindowPolicy	Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.
Vertex	Represents a unit of data processing in a Jet computation job.
Watermark	Watermark is an item occasionally inserted into a disordered (sub)stream of timestamped items.

Enum Summary

Enum	Description
Edge.RoutingPolicy	An edge describes a connection from many upstream processors to many downstream processors.
JobStatus	Represents current status of the job from the perspective of the job coordinator.
TimestampKind	Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp.

Exception Summary

Exception	Description
JobNotFoundException	Thrown when a job could not be found on the master node
TopologyChangedException	Thrown when a topology change causes a job to abort.