Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Apache Kafka reader/writer support for Hazelcast Jet.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
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.
|
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. |
ProcessorMetaSupplier
Factory of
ProcessorSupplier instances. |
Class and Description |
---|
AbstractProcessor.FlatMapper
A helper that simplifies the implementation of
tryProcess(ordinal, item) for emitting collections. |
BroadcastKey
Marker interface for a key in the snapshot state that indicates 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.
|
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. |
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.
|
WatermarkEmissionPolicy
A policy object that decides when when the watermark has advanced
enough to emit a new watermark item.
|
WatermarkPolicy
A policy object that decides on the watermark in a single data
(sub)stream.
|
WindowDefinition
Contains parameters that define a sliding/tumbling window over which Jet
will apply an aggregate function.
|
Class and Description |
---|
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. |
ProcessorMetaSupplier
Factory of
ProcessorSupplier instances. |
ProcessorSupplier
Factory of
Processor instances. |
TimestampKind
Enumerates the two possible kinds of timestamp: event timestamp and
frame timestamp.
|
WatermarkEmissionPolicy
A policy object that decides when when the watermark has advanced
enough to emit a new watermark item.
|
WatermarkPolicy
A policy object that decides on the watermark in a single data
(sub)stream.
|
WindowDefinition
Contains parameters that define a sliding/tumbling window over which Jet
will apply an aggregate function.
|
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. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.