InProcessPipelineRunner (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

@Experimental
public class InProcessPipelineRunner
extends PipelineRunner<InProcessPipelineRunner.InProcessPipelineResult>

An In-Memory implementation of the Dataflow Programming Model. Supports Unbounded PCollections.

Nested Classes
Modifier and Type	Class and Description
`static interface`	`InProcessPipelineRunner.CommittedBundle<T>` Part of a `PCollection`.
`static class`	`InProcessPipelineRunner.InProcessPipelineResult` The result of running a `Pipeline` with the `InProcessPipelineRunner`.
`static interface`	`InProcessPipelineRunner.PCollectionViewWriter<ElemT,ViewT>` A `InProcessPipelineRunner.PCollectionViewWriter` is responsible for writing contents of a `PCollection` to a storage mechanism that can be read from while constructing a `PCollectionView`.
`static interface`	`InProcessPipelineRunner.UncommittedBundle<T>` Part of a `PCollection`.

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`<OutputT extends POutput,InputT extends PInput> OutputT`	`apply(PTransform<InputT,OutputT> transform, InputT input)` Applies a transform to the given input, returning the output.
`static InProcessPipelineRunner`	`fromOptions(PipelineOptions options)`
`InProcessPipelineOptions`	`getPipelineOptions()` Returns the `PipelineOptions` used to create this `InProcessPipelineRunner`.
`InProcessPipelineRunner.InProcessPipelineResult`	`run(Pipeline pipeline)` Processes the given Pipeline, returning the results.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2020-09-08 UTC.