# Package com.hazelcast.jet.core

Jet's Core API.

See: Description

- 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 to 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.

## Package com.hazelcast.jet.core Description

Jet's Core API.

Since:
  3.0

Copyright © 2019. All rights reserved.