Package org.apache.beam.runners.jet

Implementation of the Beam runner for Hazelcast Jet.

Interface Summary

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 Summary

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	Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the JetRunner.
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.