| Package | Description |
|---|---|
| com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
| com.hazelcast.jet.avro |
Apache Avro file read/write support for Hazelcast Jet.
|
| com.hazelcast.jet.core |
Jet's Core API.
|
| com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
| com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
| com.hazelcast.jet.hadoop |
Apache Hadoop read/write support for Hazelcast Jet.
|
| com.hazelcast.jet.kafka |
Apache Kafka reader/writer support for Hazelcast Jet.
|
| com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
| com.hazelcast.jet.pipeline.file |
This package offers the
FileSourceBuilder
which allows you to construct various kinds of Pipeline sources that read from local or distributed files. |
| com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
| Class and Description |
|---|
| DAG
Describes a computation to be performed by the Jet computation engine.
|
| JobStatus
Represents current status of the job from the perspective of the job coordinator.
|
| JobSuspensionCause
Description of the cause that has led to the job being suspended.
|
| Class and Description |
|---|
| ProcessorMetaSupplier
Factory of
ProcessorSupplier instances. |
| Class and Description |
|---|
| AbstractProcessor.FlatMapper
A helper that simplifies the implementation of
tryProcess(ordinal, item) for emitting collections. |
| AppendableTraverser
A traverser with an internal
ArrayDeque. |
| BroadcastKey
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.
|
| DefaultPartitionStrategy
A facade that hides the details of Hazelcast partitioning SPI and exposes
just the partitioning strategy.
|
| Edge |
| Edge.RoutingPolicy
An edge describes a connection from many upstream processors to many
downstream processors.
|
| EventTimePolicy
A holder of functions and parameters Jet needs to handle event time and the
associated watermarks.
|
| Inbox
A subset of
Queue<Object> API restricted to the consumer side,
with additional support for bulk draining operations. |
| JobStatus
Represents current status of the job from the perspective of the job coordinator.
|
| Outbox
Data sink for a
Processor. |
| Partitioner
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. |
| SlidingWindowPolicy
Contains parameters that define a sliding/tumbling window over which Jet
will apply an aggregate function.
|
| TimestampKind
Enumerates the two possible kinds of timestamp: event timestamp and
frame timestamp.
|
| 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.
|
| WatermarkPolicy
This object tracks and determines the current
Watermark given the
event timestamps as they occur for a single input stream. |
| Class and Description |
|---|
| EventTimePolicy
A holder of functions and parameters Jet needs to handle event time and the
associated watermarks.
|
| 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. |
| ProcessorSupplier
Factory of
Processor instances. |
| SlidingWindowPolicy
Contains parameters that define a sliding/tumbling window over which Jet
will apply an aggregate function.
|
| TimestampKind
Enumerates the two possible kinds of timestamp: event timestamp and
frame timestamp.
|
| Class and Description |
|---|
| 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. |
| 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. |
| Class and Description |
|---|
| ProcessorMetaSupplier
Factory of
ProcessorSupplier instances. |
| Class and Description |
|---|
| EventTimePolicy
A holder of functions and parameters Jet needs to handle event time and the
associated watermarks.
|
| ProcessorMetaSupplier
Factory of
ProcessorSupplier instances. |
| Class and Description |
|---|
| DAG
Describes a computation to be performed by the Jet computation engine.
|
| EventTimePolicy
A holder of functions and parameters Jet needs to handle event time and the
associated watermarks.
|
| 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. |
| ProcessorSupplier
Factory of
Processor instances. |
| ProcessorSupplier.Context
Context passed to the supplier in the
init() call. |
| Class and Description |
|---|
| ProcessorMetaSupplier
Factory of
ProcessorSupplier instances. |
| Class and Description |
|---|
| AbstractProcessor
Base class to implement custom processors.
|
| EventTimePolicy
A holder of functions and parameters Jet needs to handle event time and the
associated watermarks.
|
| 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. |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.