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 ofQueue<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 aProcessor
.Partitioner<T> Encapsulates the logic associated with aDAG
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 ofProcessor
on each cluster member to do the work of a given vertex.Processor.Context Context passed to the processor in theinit()
call.ProcessorMetaSupplier Factory ofProcessorSupplier
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 ofProcessor
instances.ProcessorSupplier.Context Context passed to the supplier in theinit()
call.WatermarkPolicy This object tracks and determines the currentWatermark
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 internalArrayDeque
.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 EventTimeMapper<T> A utility that helps a source emit events according to a givenEventTimePolicy
.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 givenProcessorSupplier
on a node with givenAddress
.ResettableSingletonTraverser<T> Traverses over a single item which can be set from the outside, by using this traverser as aConsumer<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 nodeTopologyChangedException Thrown when a topology change causes a job to abort.