public class DirectRunner extends PipelineRunner<DirectRunner.DirectPipelineResult>
PipelineRunnerthat executes a
Pipelinewithin the process that constructed the
DirectRunner is suitable for running a
Pipeline on small scale, example,
and test data, and should be used for ensuring that processing logic is correct. It also is
appropriate for executing unit tests and performs additional work to ensure that behavior
contained within a
Pipeline does not break assumptions within the Beam model, to improve
the ability to execute a
Pipeline at scale on a distributed backend.
|Modifier and Type||Class and Description|
The result of running a
|Modifier and Type||Method and Description|
Processes the given
create, run, run
public static DirectRunner fromOptions(PipelineOptions options)
DirectRunnerfrom the provided options.
public DirectRunner.DirectPipelineResult run(Pipeline pipeline)
Pipeline, potentially asynchronously, returning a runner-specific type of result.