InProcessPipelineRunner (Google Cloud Dataflow SDK 1.7.0 API)

@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.

Class InProcessPipelineRunner