org.apache.beam.runners.dataflow.util

Class DoFnInfo<InputT,OutputT>

java.lang.Object

org.apache.beam.runners.dataflow.util.DoFnInfo<InputT,OutputT>

Type Parameters:

InputT - the type of the (main) input elements of the DoFn

OutputT - the type of the (main) output elements of the DoFn

All Implemented Interfaces:

java.io.Serializable

public class DoFnInfo<InputT,OutputT>
extends java.lang.Object
implements java.io.Serializable

Wrapper class holding the necessary information to serialize a DoFn.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
static <InputT,OutputT> DoFnInfo<InputT,OutputT>	forFn(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy, java.lang.Iterable<PCollectionView<?>> sideInputViews, Coder<InputT> inputCoder, long mainOutput, java.util.Map<java.lang.Long,TupleTag<?>> outputMap) Creates a DoFnInfo for the given DoFn.
static <InputT,OutputT> DoFnInfo<InputT,OutputT>	forFn(java.io.Serializable doFn, WindowingStrategy<?,?> windowingStrategy, java.lang.Iterable<PCollectionView<?>> sideInputViews, Coder<InputT> inputCoder, long mainOutput, java.util.Map<java.lang.Long,TupleTag<?>> outputMap) Deprecated.
DoFn<InputT,OutputT>	getDoFn() Returns the embedded function.
java.io.Serializable	getFn() Deprecated.
Coder<InputT>	getInputCoder()
long	getMainOutput()
java.util.Map<java.lang.Long,TupleTag<?>>	getOutputMap()
java.lang.Iterable<PCollectionView<?>>	getSideInputViews()
WindowingStrategy<?,?>	getWindowingStrategy()
DoFnInfo<InputT,OutputT>	withFn(DoFn<InputT,OutputT> newFn)

Methods inherited from class java.lang.Object

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

Method Detail

forFn

public static <InputT,OutputT> DoFnInfo<InputT,OutputT> forFn(DoFn<InputT,OutputT> doFn,
                                                              WindowingStrategy<?,?> windowingStrategy,
                                                              java.lang.Iterable<PCollectionView<?>> sideInputViews,
                                                              Coder<InputT> inputCoder,
                                                              long mainOutput,
                                                              java.util.Map<java.lang.Long,TupleTag<?>> outputMap)

Creates a DoFnInfo for the given DoFn.

forFn

@Deprecated
public static <InputT,OutputT> DoFnInfo<InputT,OutputT> forFn(java.io.Serializable doFn,
                                                                          WindowingStrategy<?,?> windowingStrategy,
                                                                          java.lang.Iterable<PCollectionView<?>> sideInputViews,
                                                                          Coder<InputT> inputCoder,
                                                                          long mainOutput,
                                                                          java.util.Map<java.lang.Long,TupleTag<?>> outputMap)

Deprecated.

TODO: remove this when Dataflow worker uses the DoFn overload.

withFn

public DoFnInfo<InputT,OutputT> withFn(DoFn<InputT,OutputT> newFn)

getFn

@Deprecated
public java.io.Serializable getFn()

Deprecated.

TODO: remove this when Dataflow worker uses getDoFn().

getDoFn

public DoFn<InputT,OutputT> getDoFn()

Returns the embedded function.

getWindowingStrategy

public WindowingStrategy<?,?> getWindowingStrategy()

getSideInputViews

public java.lang.Iterable<PCollectionView<?>> getSideInputViews()

getInputCoder

public Coder<InputT> getInputCoder()

getMainOutput

public long getMainOutput()

getOutputMap

public java.util.Map<java.lang.Long,TupleTag<?>> getOutputMap()