See: Description
| Interface | Description |
|---|---|
| PortablePipelineResult |
Result of a portable
PortablePipelineRunner.run(RunnerApi.Pipeline, JobInfo). |
| PortablePipelineRunner |
Runs a portable Beam pipeline on some execution engine.
|
| 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.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.
|