org.apache.beam.sdk.transforms

Class DoFnTester<InputT,OutputT>

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable

Deprecated.

Use TestPipeline with the DirectRunner.

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

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and 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.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> java.util.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.
java.util.List<OutputT>	peekOutputElements() Deprecated. Use TestPipeline with the DirectRunner.
<T> java.util.List<T>	peekOutputElements(TupleTag<T> tag) Deprecated. Use TestPipeline with the DirectRunner.
java.util.List<TimestampedValue<OutputT>>	peekOutputElementsInWindow(BoundedWindow window) Deprecated. Use TestPipeline with the DirectRunner.
java.util.List<TimestampedValue<OutputT>>	peekOutputElementsInWindow(TupleTag<OutputT> tag, BoundedWindow window) Deprecated. Use TestPipeline with the DirectRunner.
java.util.List<TimestampedValue<OutputT>>	peekOutputElementsWithTimestamp() Deprecated. Use TestPipeline with the DirectRunner.
java.util.List<OutputT>	processBundle(InputT... inputElements) Deprecated. Use TestPipeline with the DirectRunner.
java.util.List<OutputT>	processBundle(java.lang.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(java.util.Map<PCollectionView<?>,java.util.Map<BoundedWindow,?>> sideInputs) Deprecated. Use TestPipeline with the DirectRunner.
void	startBundle() Deprecated. Use TestPipeline with the DirectRunner.
java.util.List<OutputT>	takeOutputElements() Deprecated. Use TestPipeline with the DirectRunner.
<T> java.util.List<T>	takeOutputElements(TupleTag<T> tag) Deprecated. Use TestPipeline with the DirectRunner.
java.util.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 Detail

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(java.util.Map<PCollectionView<?>,java.util.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 java.util.List<OutputT> processBundle(java.lang.Iterable<? extends InputT> inputElements)
                                                  throws java.lang.Exception

Deprecated. Use TestPipeline with the DirectRunner.

Throws:

java.lang.Exception

processBundle

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

Deprecated. Use TestPipeline with the DirectRunner.

Throws:

java.lang.Exception

startBundle

@Deprecated
public void startBundle()
                             throws java.lang.Exception

Deprecated. Use TestPipeline with the DirectRunner.

Throws:

java.lang.Exception

processElement

@Deprecated
public void processElement(InputT element)
                                throws java.lang.Exception

Deprecated. Use TestPipeline with the DirectRunner.

Throws:

java.lang.Exception

processTimestampedElement

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

Deprecated. Use TestPipeline with the DirectRunner.

Throws:

java.lang.Exception

processWindowedElement

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

Deprecated. Use TestPipeline with the DirectRunner.

Throws:

java.lang.Exception

finishBundle

@Deprecated
public void finishBundle()
                              throws java.lang.Exception

Deprecated. Use TestPipeline with the DirectRunner.

Throws:

java.lang.Exception

peekOutputElements

@Deprecated
public java.util.List<OutputT> peekOutputElements()

Deprecated. Use TestPipeline with the DirectRunner.

peekOutputElementsWithTimestamp

@Deprecated
public java.util.List<TimestampedValue<OutputT>> peekOutputElementsWithTimestamp()

Deprecated. Use TestPipeline with the DirectRunner.

peekOutputElementsInWindow

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

Deprecated. Use TestPipeline with the DirectRunner.

peekOutputElementsInWindow

@Deprecated
public java.util.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 java.util.List<OutputT> takeOutputElements()

Deprecated. Use TestPipeline with the DirectRunner.

takeOutputElementsWithTimestamp

@Deprecated
public java.util.List<TimestampedValue<OutputT>> takeOutputElementsWithTimestamp()

Deprecated. Use TestPipeline with the DirectRunner.

peekOutputElements

@Deprecated
public <T> java.util.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> java.util.List<T> takeOutputElements(TupleTag<T> tag)

Deprecated. Use TestPipeline with the DirectRunner.

getMutableOutput

@Deprecated
public <T> java.util.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.ProcessContext createProcessContext(ValueInSingleWindow<InputT> element)

Deprecated. Use TestPipeline with the DirectRunner.

close

@Deprecated
public void close()
                       throws java.lang.Exception

Deprecated. Use TestPipeline with the DirectRunner.

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception