Package org.apache.beam.runners.local

package org.apache.beam.runners.local

Utilities useful when executing a pipeline on a single machine.

Class	Description
Bundle<T,CollectionT>	An immutable collection of elements which are part of a PCollection.
ExecutionDriver	Drives the execution of a Pipeline by scheduling work.
ExecutionDriver.DriverState	The state of the driver.
PipelineMessageReceiver	Handles failures in the form of exceptions.
StructuralKey<K>	A (Key, Coder) pair that uses the structural value of the key (as provided by Coder.structuralValue(Object)) to perform equality and hashing.