Jet's Core API.
Interface Summary Interface Description DefaultPartitionStrategyA facade that hides the details of Hazelcast partitioning SPI and exposes just the partitioning strategy. InboxA subset of
Queue<Object>API restricted to the consumer side, with additional support for bulk draining operations.
JobSuspensionCauseDescription of the cause that has led to the job being suspended. OutboxData sink for a
Partitioner<T>Encapsulates the logic associated with a
DAGedge that decides on the partition ID of an item traveling over it.
ProcessorWhen Jet executes a DAG, it creates one or more instances of
Processoron each cluster member to do the work of a given vertex.
Processor.ContextContext passed to the processor in the
ProcessorMetaSupplier.ContextContext passed to the meta-supplier at init time on the member that received a job request from the client. ProcessorSupplierFactory of
ProcessorSupplier.ContextContext passed to the supplier in the
WatermarkPolicyThis object tracks and determines the current
Watermarkgiven the event timestamps as they occur for a single input stream.
Class Summary Class Description AbstractProcessorBase class to implement custom processors. AppendableTraverser<T>A traverser with an internal
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. DAGDescribes a computation to be performed by the Jet computation engine. Edge EventTimeMapper<T>A utility that helps a source emit events according to a given
EventTimePolicy<T>A holder of functions and parameters Jet needs to handle event time and the associated watermarks. JetDataSerializerHookA Java Service Provider hook for Hazelcast's Identified Data Serializable mechanism. JetPropertiesDefines the names and default values for internal Hazelcast Jet properties. Partitioner.DefaultPartitioner which applies the default Hazelcast partitioning strategy. ResettableSingletonTraverser<T>Traverses over a single item which can be set from the outside, by using this traverser as a
SlidingWindowPolicyContains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function. VertexRepresents a unit of data processing in a Jet computation job. WatermarkWatermark is an item occasionally inserted into a disordered (sub)stream of timestamped items.
Enum Summary Enum Description Edge.RoutingPolicyAn edge describes a connection from many upstream processors to many downstream processors. JobStatusRepresents current status of the job from the perspective of the job coordinator. TimestampKindEnumerates the two possible kinds of timestamp: event timestamp and frame timestamp.
Exception Summary Exception Description JobNotFoundExceptionThrown when a job could not be found on the master node TopologyChangedExceptionThrown when a topology change causes a job to abort.