Package org.apache.beam.runners.jet

package org.apache.beam.runners.jet

Implementation of the Beam runner for Hazelcast Jet.

Related Packages

Package	Description
org.apache.beam.runners.jet.metrics	Helper classes for implementing metrics in the Hazelcast Jet based runner.
org.apache.beam.runners.jet.processors	Individual DAG node processors used by the Beam runner for Hazelcast Jet.

Class	Description
DAGBuilder	Utility class for wiring up Jet DAGs based on Beam pipelines.
DAGBuilder.WiringListener	Listener that can be registered with a DAGBuilder in order to be notified when edges are being registered.
FailedRunningPipelineResults	Alternative implementation of PipelineResult used to avoid throwing Exceptions in certain situations.
JetPipelineOptions	Pipeline options specific to the Jet runner.
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.