| Interface | Description |
|---|---|
| BroadcastKey<K> |
Marker interface for a key in the snapshot state that indicates the
corresponding entry should be broadcast to all processors
when restoring the snapshot.
|
| 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. |
| WatermarkEmissionPolicy |
A policy object that decides when the watermark has advanced enough to
require emitting a new watermark item.
|
| WatermarkPolicy |
This object runs inside a Jet processor, inspects the event timestamps
as they occur in the input and and decides on the current value of the
watermark.
|
| Class | Description |
|---|---|
| AbstractProcessor |
Base class to implement custom processors.
|
| AppendableTraverser<T> |
A traverser with an internal
ArrayDeque. |
| DAG |
Describes a computation to be performed by the Jet computation engine.
|
| Edge | |
| JetDataSerializerHook |
A Java Service Provider hook for Hazelcast's Identified Data Serializable
mechanism.
|
| 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.
|
| WatermarkGenerationParams<T> |
A holder of functions and parameters Jet needs to determine when and how
to insert watermarks into an event stream.
|
| WatermarkPolicies |
Utility class with factories of several useful watermark policies.
|
| WatermarkSourceUtil<T> |
A utility to help emitting
Watermarks from a source which reads
events from multiple external partitions. |
| 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 | 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.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.