Package org.apache.beam.sdk.transforms

Class DoFnTester<InputT,OutputT>

java.lang.Object

org.apache.beam.sdk.transforms.DoFnTester<InputT,OutputT>

All Implemented Interfaces:

AutoCloseable

@Deprecated
public class DoFnTester<InputT,OutputT>
extends Object
implements AutoCloseable

Deprecated.

Use TestPipeline with the DirectRunner.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DoFnTester.CloningBehavior	Deprecated. Use TestPipeline with the DirectRunner.

Method Summary

Modifier and Type	Method	Description
void	clearOutputElements()	Deprecated. Use TestPipeline with the DirectRunner.
<T> void	clearOutputElements(TupleTag<T> tag)	Deprecated. Use TestPipeline with the DirectRunner.
void	close()	Deprecated. Use TestPipeline with the DirectRunner.
DoFn<InputT,OutputT>.ProcessContext	createProcessContext(ValueInSingleWindow<InputT> element)	Deprecated. Use TestPipeline with the DirectRunner.
void	finishBundle()	Deprecated. Use TestPipeline with the DirectRunner.
DoFnTester.CloningBehavior	getCloningBehavior()	Deprecated. Use TestPipeline with the DirectRunner.
TupleTag<OutputT>	getMainOutputTag()	Deprecated. Use TestPipeline with the DirectRunner.
<T> List<ValueInSingleWindow<T>>	getMutableOutput(TupleTag<T> tag)	Deprecated. Use TestPipeline with the DirectRunner.
PipelineOptions	getPipelineOptions()	Deprecated. Use TestPipeline with the DirectRunner.
static <InputT, OutputT> DoFnTester<InputT,OutputT>	of(DoFn<InputT,OutputT> fn)	Deprecated. Use TestPipeline with the DirectRunner.
List<OutputT>	peekOutputElements()	Deprecated. Use TestPipeline with the DirectRunner.
<T> List<T>	peekOutputElements(TupleTag<T> tag)	Deprecated. Use TestPipeline with the DirectRunner.
List<TimestampedValue<OutputT>>	peekOutputElementsInWindow(BoundedWindow window)	Deprecated. Use TestPipeline with the DirectRunner.
List<TimestampedValue<OutputT>>	peekOutputElementsInWindow(TupleTag<OutputT> tag, BoundedWindow window)	Deprecated. Use TestPipeline with the DirectRunner.
List<TimestampedValue<OutputT>>	peekOutputElementsWithTimestamp()	Deprecated. Use TestPipeline with the DirectRunner.
final List<OutputT>	processBundle(InputT... inputElements)	Deprecated. Use TestPipeline with the DirectRunner.
List<OutputT>	processBundle(Iterable<? extends InputT> inputElements)	Deprecated. Use TestPipeline with the DirectRunner.
void	processElement(InputT element)	Deprecated. Use TestPipeline with the DirectRunner.
void	processTimestampedElement(TimestampedValue<InputT> element)	Deprecated. Use TestPipeline with the DirectRunner.
void	processWindowedElement(InputT element, Instant timestamp, BoundedWindow window)	Deprecated. Use TestPipeline with the DirectRunner.
void	setCloningBehavior(DoFnTester.CloningBehavior newValue)	Deprecated. Use TestPipeline with the DirectRunner.
<T> void	setSideInput(PCollectionView<T> sideInput, BoundedWindow window, T value)	Deprecated. Use TestPipeline with the DirectRunner.
void	setSideInputs(Map<PCollectionView<?>,Map<BoundedWindow,?>> sideInputs)	Deprecated. Use TestPipeline with the DirectRunner.
void	startBundle()	Deprecated. Use TestPipeline with the DirectRunner.
List<OutputT>	takeOutputElements()	Deprecated. Use TestPipeline with the DirectRunner.
<T> List<T>	takeOutputElements(TupleTag<T> tag)	Deprecated. Use TestPipeline with the DirectRunner.
List<TimestampedValue<OutputT>>	takeOutputElementsWithTimestamp()	Deprecated. Use TestPipeline with the DirectRunner.

Methods inherited from class java.lang.Object

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

Method Details

of

@Deprecated
public static <InputT,
OutputT>
DoFnTester<InputT,OutputT> of(DoFn<InputT,OutputT> fn)

Deprecated.

Use TestPipeline with the DirectRunner.

setSideInputs

@Deprecated
public void setSideInputs(Map<PCollectionView<?>,Map<BoundedWindow,?>> sideInputs)

Deprecated.

Use TestPipeline with the DirectRunner.

setSideInput

@Deprecated
public <T> void setSideInput(PCollectionView<T> sideInput,
 BoundedWindow window,
 T value)

Deprecated.

Use TestPipeline with the DirectRunner.

getPipelineOptions

@Deprecated
public PipelineOptions getPipelineOptions()

Deprecated.

Use TestPipeline with the DirectRunner.

setCloningBehavior

@Deprecated
public void setCloningBehavior(DoFnTester.CloningBehavior newValue)

Deprecated.

Use TestPipeline with the DirectRunner.

getCloningBehavior

@Deprecated
public DoFnTester.CloningBehavior getCloningBehavior()

Deprecated.

Use TestPipeline with the DirectRunner.

processBundle

@Deprecated
public List<OutputT> processBundle(Iterable<? extends InputT> inputElements)
                            throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Throws:

Exception

processBundle

@Deprecated
@SafeVarargs
public final List<OutputT> processBundle(InputT... inputElements)
                                  throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Throws:

Exception

startBundle

@Deprecated
public void startBundle()
                 throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Throws:

Exception

processElement

@Deprecated
public void processElement(InputT element)
                    throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Throws:

Exception

processTimestampedElement

@Deprecated
public void processTimestampedElement(TimestampedValue<InputT> element)
                               throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Throws:

Exception

processWindowedElement

@Deprecated
public void processWindowedElement(InputT element,
 Instant timestamp,
 BoundedWindow window)
                            throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Throws:

Exception

finishBundle

@Deprecated
public void finishBundle()
                  throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Throws:

Exception

peekOutputElements

@Deprecated
public List<OutputT> peekOutputElements()

Deprecated.

Use TestPipeline with the DirectRunner.

peekOutputElementsWithTimestamp

@Deprecated
public List<TimestampedValue<OutputT>> peekOutputElementsWithTimestamp()

Deprecated.

Use TestPipeline with the DirectRunner.

peekOutputElementsInWindow

@Deprecated
public List<TimestampedValue<OutputT>> peekOutputElementsInWindow(BoundedWindow window)

Deprecated.

Use TestPipeline with the DirectRunner.

peekOutputElementsInWindow

@Deprecated
public List<TimestampedValue<OutputT>> peekOutputElementsInWindow(TupleTag<OutputT> tag,
 BoundedWindow window)

Deprecated.

Use TestPipeline with the DirectRunner.

clearOutputElements

@Deprecated
public void clearOutputElements()

Deprecated.

Use TestPipeline with the DirectRunner.

takeOutputElements

@Deprecated
public List<OutputT> takeOutputElements()

Deprecated.

Use TestPipeline with the DirectRunner.

takeOutputElementsWithTimestamp

@Deprecated
public List<TimestampedValue<OutputT>> takeOutputElementsWithTimestamp()

Deprecated.

Use TestPipeline with the DirectRunner.

peekOutputElements

@Deprecated
public <T> List<T> peekOutputElements(TupleTag<T> tag)

Deprecated.

Use TestPipeline with the DirectRunner.

clearOutputElements

@Deprecated
public <T> void clearOutputElements(TupleTag<T> tag)

Deprecated.

Use TestPipeline with the DirectRunner.

takeOutputElements

@Deprecated
public <T> List<T> takeOutputElements(TupleTag<T> tag)

Deprecated.

Use TestPipeline with the DirectRunner.

getMutableOutput

@Deprecated
public <T> List<ValueInSingleWindow<T>> getMutableOutput(TupleTag<T> tag)

Deprecated.

Use TestPipeline with the DirectRunner.

getMainOutputTag

@Deprecated
public TupleTag<OutputT> getMainOutputTag()

Deprecated.

Use TestPipeline with the DirectRunner.

createProcessContext

@Deprecated
public DoFn<InputT,OutputT>.ProcessContext createProcessContext(ValueInSingleWindow<InputT> element)

Deprecated.

Use TestPipeline with the DirectRunner.

close

@Deprecated
public void close()
           throws Exception

Deprecated.

Use TestPipeline with the DirectRunner.

Specified by:

close in interface AutoCloseable

Throws:

Exception