Uses of Package
com.hazelcast.jet.core
Package
Description
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Apache Avro file read/write support for Hazelcast Jet.
Jet's Core API.
Contains static utility classes with factories of Jet processors.
Utilities for writing tests of Core API Processors.
Apache Hadoop read/write support for Hazelcast Jet.
Apache Kafka reader/writer support for Hazelcast Jet.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
This package offers the
FileSourceBuilder
which allows you to construct various kinds of Pipeline
sources that read from local or distributed files.This package contains various mock sources to help with pipeline testing
and development.
Provides interfaces/classes for Hazelcast security implementation.
-
ClassDescriptionDescribes a computation to be performed by the Jet computation engine.Represents current status of the job from the perspective of the job coordinator.Description of the cause that has led to the job being suspended.
-
-
ClassDescriptionA helper that simplifies the implementation of
tryProcess(ordinal, item)
for emitting collections.A traverser with an internalArrayDeque
.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 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.Represents current status of the job from the perspective of the job coordinator.Data sink for aProcessor
.Encapsulates the logic associated with aDAG
edge that decides on the partition ID of an item traveling over it.When Jet executes a DAG, it creates one or more instances ofProcessor
on each cluster member to do the work of a given vertex.Context passed to the processor in theinit()
call.Factory ofProcessorSupplier
instances.Context passed to the meta-supplier at init time on the member that received a job request from the client.Factory ofProcessor
instances.Context passed to the supplier in theinit()
call.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.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 currentWatermark
given the event timestamps as they occur for a single input stream. -
ClassDescriptionA holder of functions and parameters Jet needs to handle event time and the associated watermarks.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.Context passed to the processor in theinit()
call.Factory ofProcessorSupplier
instances.Factory ofProcessor
instances.Context passed to the supplier in theinit()
call.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. -
ClassDescriptionA subset of
Queue<Object>
API restricted to the consumer side, with additional support for bulk draining operations.Data sink for aProcessor
.When Jet executes a DAG, it creates one or more instances ofProcessor
on each cluster member to do the work of a given vertex.Context passed to the processor in theinit()
call.Factory ofProcessorSupplier
instances.Context passed to the meta-supplier at init time on the member that received a job request from the client.Factory ofProcessor
instances.Context passed to the supplier in theinit()
call. -
-
ClassDescriptionA holder of functions and parameters Jet needs to handle event time and the associated watermarks.Factory of
ProcessorSupplier
instances. -
ClassDescriptionDescribes a computation to be performed by the Jet computation engine.A holder of functions and parameters Jet needs to handle event time and the associated watermarks.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.Context passed to the processor in theinit()
call.Factory ofProcessorSupplier
instances.Factory ofProcessor
instances.Context passed to the supplier in theinit()
call. -
-
ClassDescriptionBase class to implement custom processors.A holder of functions and parameters Jet needs to handle event time and the associated watermarks.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.Context passed to the processor in theinit()
call. -
ClassDescriptionContext passed to the meta-supplier at init time on the member that received a job request from the client.