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.server |
Contains Java program entry points that will start a Jet server
instance, submit jobs to a Jet cluster, etc.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Class and Description |
---|
CoGroupBuilder
Offers a step-by-step fluent API to build a co-grouping pipeline stage by
adding any number of contributing stages.
|
ComputeStage
Represents a stage in a distributed computation
pipeline . |
HashJoinBuilder
Offers a step-by-step fluent API to build a hash-join pipeline stage.
|
JetInstance
Represents either an instance of a Jet server node or a Jet client
instance that connects to a remote cluster.
|
Job
A Jet computation job created from a
DAG . |
JoinClause
Specifies how to join an enriching stream to the primary stream in a
hash-join
operation. |
Pipeline
Models a distributed computation job using an analogy with a system of
interconnected water pipes.
|
Sink
A transform which accepts an input stream and produces no output
streams.
|
SinkStage
A pipeline stage that doesn't allow any downstream stages to be attached
to it.
|
Source
A transform that takes no input streams and produces an output stream.
|
Stage
The basic element of a Jet
pipeline . |
Transform
Represents the data transformation performed by a pipeline
Stage . |
Traverser
Traverses a potentially infinite sequence of non-
null items. |
Class and Description |
---|
JetException
Base Jet exception.
|
JetInstance
Represents either an instance of a Jet server node or a Jet client
instance that connects to a remote cluster.
|
Traverser
Traverses a potentially infinite sequence of non-
null items. |
Class and Description |
---|
Traverser
Traverses a potentially infinite sequence of non-
null items. |
Class and Description |
---|
JetInstance
Represents either an instance of a Jet server node or a Jet client
instance that connects to a remote cluster.
|
Class and Description |
---|
JetInstance
Represents either an instance of a Jet server node or a Jet client
instance that connects to a remote cluster.
|
Class and Description |
---|
JetInstance
Represents either an instance of a Jet server node or a Jet client
instance that connects to a remote cluster.
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.