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.
ReferenceRunnerJobServer.ServerConfiguration	Command-line options to configure the JobServer.
ReferenceRunnerJobService	This JobService implements the grpc calls for running jobs by using the ReferenceRunner as an engine.
ReferenceRunnerJobService.Configuration	A configuration object for constructing the ReferenceRunnerJobService.

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.