com.google.cloud.dataflow.sdk.util

Class DoFnInfo<InputT,OutputT>

java.lang.Object

com.google.cloud.dataflow.sdk.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:

Serializable

public class DoFnInfo<InputT,OutputT>
extends Object
implements Serializable

Wrapper class holding the necessary information to serialize a DoFn.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DoFnInfo(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy)
DoFnInfo(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy, Iterable<PCollectionView<?>> sideInputViews, Coder<InputT> inputCoder)

Method Summary

Modifier and Type	Method and Description
DoFn<InputT,OutputT>	getDoFn()
Coder<InputT>	getInputCoder()
Iterable<PCollectionView<?>>	getSideInputViews()
WindowingStrategy<?,?>	getWindowingStrategy()

Methods inherited from class java.lang.Object

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

Constructor Detail

DoFnInfo

public DoFnInfo(DoFn<InputT,OutputT> doFn,
                WindowingStrategy<?,?> windowingStrategy)

DoFnInfo

public DoFnInfo(DoFn<InputT,OutputT> doFn,
                WindowingStrategy<?,?> windowingStrategy,
                Iterable<PCollectionView<?>> sideInputViews,
                Coder<InputT> inputCoder)

Method Detail

getDoFn

public DoFn<InputT,OutputT> getDoFn()

getWindowingStrategy

public WindowingStrategy<?,?> getWindowingStrategy()

getSideInputViews

public Iterable<PCollectionView<?>> getSideInputViews()

getInputCoder

public Coder<InputT> getInputCoder()