See: Description
| Interface | Description |
|---|---|
| DAGBuilder.WiringListener |
Listener that can be registered with a
DAGBuilder in order to be notified when edges
are being registered. |
| JetPipelineOptions |
Pipeline options specific to the Jet runner.
|
| Class | Description |
|---|---|
| DAGBuilder |
Utility class for wiring up Jet DAGs based on Beam pipelines.
|
| FailedRunningPipelineResults |
Alternative implementation of
PipelineResult used to avoid throwing Exceptions in certain
situations. |
| JetPipelineResult |
Jet specific implementation of
PipelineResult. |
| JetRunner |
Jet specific implementation of Beam's
PipelineRunner. |
| JetRunnerRegistrar | |
| JetRunnerRegistrar.Options |
Registers the
JetPipelineOptions. |
| JetRunnerRegistrar.Runner |
Registers the
JetRunner. |
| Utils |
Various common methods used by the Jet based runner.
|
| Utils.ByteArrayKey |
A wrapper of
byte[] that can be used as a hash-map key. |