Class ProtoPrintingRunner

A runner that simply prints the pipeline definition and returns.

Hierarchy

Runner
- ProtoPrintingRunner

Index

Constructors

Methods

run runAsync runPipeline

Constructors

constructor

new ProtoPrintingRunner(): ProtoPrintingRunner
Returns ProtoPrintingRunner

Inherited from Runner.constructor

Methods

run

run(pipeline: ((root: Root) => PValue<any> | Promise<PValue<any>>), options?: Object): Promise<PipelineResult>
Runs the transform.

Resolves to an instance of PipelineResult when the pipeline completes. Use runAsync() to execute the pipeline in the background.

Returns
A PipelineResult
Parameters
- pipeline: ((root: Root) => PValue<any> | Promise<PValue<any>>)
  - - (root: Root): PValue<any> | Promise<PValue<any>>
    - Parameters
      
      root: Root
      
      Returns PValue<any> | Promise<PValue<any>>
- Optional options: Object
Returns Promise<PipelineResult>
Inherited from Runner.run
- Defined in src/apache_beam/runners/runner.ts:102

runAsync

runAsync(pipeline: ((root: Root) => PValue<any> | Promise<PValue<any>>), options?: Object): Promise<PipelineResult>
runAsync() is the asynchronous version of run(), does not wait until pipeline finishes. Use the returned PipelineResult to query job status.
Parameters
- pipeline: ((root: Root) => PValue<any> | Promise<PValue<any>>)
  - - (root: Root): PValue<any> | Promise<PValue<any>>
    - Parameters
      
      root: Root
      
      Returns PValue<any> | Promise<PValue<any>>
- Optional options: Object
Returns Promise<PipelineResult>
Inherited from Runner.runAsync
- Defined in src/apache_beam/runners/runner.ts:120

runPipeline

runPipeline(pipeline: any): Promise<PipelineResult>
Parameters
- pipeline: any
Returns Promise<PipelineResult>
Overrides Runner.runPipeline
- Defined in src/apache_beam/testing/proto_printing_runner.ts:25

Generated using TypeDoc