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|
|Modifier and Type||Method and Description|
Processes the given
public static DirectRunner fromOptions(PipelineOptions options)
DirectRunnerfrom the provided options.
public DirectOptions getPipelineOptions()
public DirectRunner.DirectPipelineResult run(Pipeline originalPipeline)
Pipeline, potentially asynchronously, returning a runner-specific type of result.