Package org.apache.beam.sdk.util
Class DoFnInfo<InputT,OutputT>
- java.lang.Object
-
- org.apache.beam.sdk.util.DoFnInfo<InputT,OutputT>
-
- Type Parameters:
InputT
- the type of the (main) input elements of theDoFn
OutputT
- the type of the (main) output elements of theDoFn
- All Implemented Interfaces:
java.io.Serializable
@Internal public class DoFnInfo<InputT,OutputT> extends java.lang.Object implements java.io.Serializable
Wrapper class holding the necessary information to serialize aDoFn
.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <InputT,OutputT>
DoFnInfo<InputT,OutputT>forFn(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy, java.lang.Iterable<PCollectionView<?>> sideInputViews, Coder<InputT> inputCoder, java.util.Map<TupleTag<?>,Coder<?>> outputCoders, TupleTag<OutputT> mainOutput, DoFnSchemaInformation doFnSchemaInformation, java.util.Map<java.lang.String,PCollectionView<?>> sideInputMapping)
static <InputT,OutputT>
DoFnInfo<InputT,OutputT>forFn(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy, java.lang.Iterable<PCollectionView<?>> sideInputViews, Coder<InputT> inputCoder, TupleTag<OutputT> mainOutput, DoFnSchemaInformation doFnSchemaInformation, java.util.Map<java.lang.String,PCollectionView<?>> sideInputMapping)
DoFn<InputT,OutputT>
getDoFn()
Returns the embedded function.DoFnSchemaInformation
getDoFnSchemaInformation()
Coder<InputT>
getInputCoder()
TupleTag<OutputT>
getMainOutput()
java.util.Map<TupleTag<?>,Coder<?>>
getOutputCoders()
java.util.Map<java.lang.String,PCollectionView<?>>
getSideInputMapping()
java.lang.Iterable<PCollectionView<?>>
getSideInputViews()
WindowingStrategy<?,?>
getWindowingStrategy()
DoFnInfo<InputT,OutputT>
withFn(DoFn<InputT,OutputT> newFn)
-
-
-
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, TupleTag<OutputT> mainOutput, DoFnSchemaInformation doFnSchemaInformation, java.util.Map<java.lang.String,PCollectionView<?>> sideInputMapping)
-
forFn
public static <InputT,OutputT> DoFnInfo<InputT,OutputT> forFn(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy, java.lang.Iterable<PCollectionView<?>> sideInputViews, Coder<InputT> inputCoder, java.util.Map<TupleTag<?>,Coder<?>> outputCoders, TupleTag<OutputT> mainOutput, DoFnSchemaInformation doFnSchemaInformation, java.util.Map<java.lang.String,PCollectionView<?>> sideInputMapping)
-
getWindowingStrategy
public WindowingStrategy<?,?> getWindowingStrategy()
-
getSideInputViews
public java.lang.Iterable<PCollectionView<?>> getSideInputViews()
-
getDoFnSchemaInformation
public DoFnSchemaInformation getDoFnSchemaInformation()
-
getSideInputMapping
public java.util.Map<java.lang.String,PCollectionView<?>> getSideInputMapping()
-
-