Package org.apache.beam.sdk.testing

Class TestOutputReceiver<T>

java.lang.Object

org.apache.beam.sdk.testing.TestOutputReceiver<T>

All Implemented Interfaces:

DoFn.OutputReceiver<T>

@Internal
public class TestOutputReceiver<T>
extends Object
implements DoFn.OutputReceiver<T>

An implementation of DoFn.OutputReceiver that naively collects all output values.

Because this API is crude and not designed to be very general, it is for internal use only and will be changed arbitrarily.

Constructor Summary

Constructors

Constructor	Description
TestOutputReceiver()

Method Summary

Modifier and Type	Method	Description
OutputBuilder<T>	builder(T value)
List<T>	getOutputs()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.transforms.DoFn.OutputReceiver

output, outputWindowedValue, outputWithTimestamp

Constructor Details

TestOutputReceiver

public TestOutputReceiver()

Method Details

builder

public OutputBuilder<T> builder(T value)

Specified by:

builder in interface DoFn.OutputReceiver<T>

getOutputs

public List<T> getOutputs()