Package org.apache.beam.runners.jobsubmission

package org.apache.beam.runners.jobsubmission

Job management services for use in beam runners.

Class	Description
InMemoryJobService	A InMemoryJobService that prepares and runs jobs on behalf of a client using a JobInvoker.
JobInvocation	Internal representation of a Job which has been invoked (prepared and run) by a client.
JobInvoker	Factory to create JobInvocation instances.
JobPreparation	A job that has been prepared, but not invoked.
JobServerDriver	Shared code for starting and serving an InMemoryJobService.
JobServerDriver.JobInvokerFactory
JobServerDriver.ServerConfiguration	Configuration for the jobServer.
PortablePipelineJarCreator	PortablePipelineRunner that bundles the input pipeline along with all dependencies, artifacts, etc.
PortablePipelineJarUtils	Contains common code for writing and reading portable pipeline jars.
PortablePipelineResult	Result of a portable PortablePipelineRunner.run(RunnerApi.Pipeline, JobInfo).
PortablePipelineRunner	Runs a portable Beam pipeline on some execution engine.