Runs a portable Beam pipeline on some execution engine.
A InMemoryJobService that prepares and runs jobs on behalf of a client using a
Internal representation of a Job which has been invoked (prepared and run) by a client.
Factory to create
A job that has been prepared, but not invoked.
Shared code for starting and serving an
Configuration for the jobServer.