com.google.cloud.dataflow.sdk.util

Class DoFnRunner.ListOutputManager

java.lang.Object

com.google.cloud.dataflow.sdk.util.DoFnRunner.ListOutputManager

All Implemented Interfaces:

DoFnRunner.OutputManager

Enclosing class:

DoFnRunner<InputT,OutputT>

public static class DoFnRunner.ListOutputManager
extends Object
implements DoFnRunner.OutputManager

An implementation of DoFnRunner.OutputManager using simple lists, for testing and in-memory contexts such as the DirectPipelineRunner.

Constructor Summary

Constructors

Constructor and Description
ListOutputManager()

Method Summary

Modifier and Type	Method and Description
<T> List<WindowedValue<T>>	getOutput(TupleTag<T> tag)
<T> void	output(TupleTag<T> tag, WindowedValue<T> output) Outputs a single element to the receiver indicated by the given TupleTag.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ListOutputManager

public ListOutputManager()

Method Detail

output

public <T> void output(TupleTag<T> tag,
                       WindowedValue<T> output)

Description copied from interface: DoFnRunner.OutputManager

Outputs a single element to the receiver indicated by the given TupleTag.

Specified by:

output in interface DoFnRunner.OutputManager

getOutput

public <T> List<WindowedValue<T>> getOutput(TupleTag<T> tag)