Package com.hazelcast.jet.core

Jet's Core API.
Since:
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.
    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.
    JetProperties
    Defines the names and default values for internal Hazelcast Jet properties.
    Partitioner.Default
    Partitioner 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 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.