Package org.apache.beam.runners.direct.portable.job

An execution engine for Beam Pipelines that uses the Java Runner harness and the Fn API to execute.

See: Description

Class Summary

Class	Description
ReferenceRunnerJobServer	A program that runs a ReferenceRunnerJobService.
ReferenceRunnerJobService	The ReferenceRunner uses the portability framework to execute a Pipeline on a single machine.

Package org.apache.beam.runners.direct.portable.job Description

An execution engine for Beam Pipelines that uses the Java Runner harness and the Fn API to execute.