com.google.cloud.dataflow.sdk.runners (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Package com.google.cloud.dataflow.sdk.runners

Defines runners for executing Pipelines in different modes, including DirectPipelineRunner and DataflowPipelineRunner.

See: Description

Package com.google.cloud.dataflow.sdk.runners Description

Defines runners for executing Pipelines in different modes, including DirectPipelineRunner and DataflowPipelineRunner.

DirectPipelineRunner executes a Pipeline locally, without contacting the Dataflow service. DataflowPipelineRunner submits a Pipeline to the Dataflow service, which executes it on Dataflow-managed Compute Engine instances. DataflowPipelineRunner returns as soon as the Pipeline has been submitted. Use BlockingDataflowPipelineRunner to have execution updates printed to the console.

The runner is specified as part PipelineOptions.


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Dataflow