Package org.apache.beam.runners.gearpump

Internal implementation of the Beam runner for Apache Gearpump.

See: Description

Interface Summary

Interface	Description
GearpumpPipelineOptions	Options that configure the Gearpump pipeline.

Class Summary

Class	Description
GearpumpPipelineResult	Result of executing a Pipeline with Gearpump.
GearpumpRunner	A PipelineRunner that executes the operations in the pipeline by first translating them to Gearpump Stream DSL and then executing them on a Gearpump cluster.
GearpumpRunnerRegistrar	Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the GearpumpRunner.
GearpumpRunnerRegistrar.Options	Registers the GearpumpPipelineOptions.
GearpumpRunnerRegistrar.Runner	Registers the GearpumpRunner.
TestGearpumpRunner	Gearpump PipelineRunner for tests, which uses EmbeddedCluster.

Package org.apache.beam.runners.gearpump Description

Internal implementation of the Beam runner for Apache Gearpump.