public class PortableRunner extends PipelineRunner<PipelineResult>
Modifier and Type | Method and Description |
---|---|
static PortableRunner |
fromOptions(PipelineOptions options)
Constructs a runner from the provided options.
|
PipelineResult |
run(Pipeline pipeline)
Processes the given
Pipeline , potentially asynchronously, returning a runner-specific
type of result. |
java.lang.String |
toString() |
create, run, run
public static PortableRunner fromOptions(PipelineOptions options)
options
- Properties which configure the runner.public PipelineResult run(Pipeline pipeline)
PipelineRunner
Pipeline
, potentially asynchronously, returning a runner-specific
type of result.run
in class PipelineRunner<PipelineResult>
public java.lang.String toString()
toString
in class java.lang.Object