Package com.hazelcast.jet.core
package com.hazelcast.jet.core
Jet's Core API.
- Since:
- Jet 3.0
-
ClassDescriptionBase class to implement custom processors.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.Describes a computation to be performed by the Jet computation engine.A facade that hides the details of Hazelcast partitioning SPI and exposes just the partitioning strategy.An edge describes a connection from many upstream processors to many downstream processors.A utility that helps a source emit events according to a givenEventTimePolicy.A holder of functions and parameters Jet needs to handle event time and the associated watermarks.A subset ofQueue<Object>API restricted to the consumer side, with additional support for bulk draining operations.A Java Service Provider hook for Hazelcast's Identified Data Serializable mechanism.Thrown when a job could not be found on the master nodeRepresents current status of the job from the perspective of the job coordinator.Description of the cause that has led to the job being suspended.Data sink for aProcessor.Partitioner<T>Encapsulates the logic associated with aDAGedge that decides on the partition ID of an item traveling over it.Partitioner which applies the default Hazelcast partitioning strategy.When Jet executes a DAG, it creates one or more instances ofProcessoron each cluster member to do the work of a given vertex.Context passed to the processor in theinit()call.Factory ofProcessorSupplierinstances.Context passed to the meta-supplier at init time on the member that received a job request from the client.A meta-supplier that will only use the givenProcessorSupplieron a node with givenAddressor random member if address is not given.Factory ofProcessorinstances.Context passed to the supplier in theinit()call.Traverses over a single item which can be set from the outside, by using this traverser as aConsumer<T>.Contains parameters that define a sliding/tumbling window over which Jet will apply an aggregate function.Enumerates the two possible kinds of timestamp: event timestamp and frame timestamp.Thrown when a topology change causes a job to abort.Represents a unit of data processing in a Jet computation job.Watermark is an item occasionally inserted into a disordered (sub)stream of timestamped items.This object tracks and determines the currentWatermarkgiven the event timestamps as they occur for a single input stream.