InputT - the type of the (main) input elements of the DoFnOutputT - the type of the (main) output elements of the DoFnpublic class DoFnInfo<InputT,OutputT> extends Object implements Serializable
| Constructor and Description |
|---|
DoFnInfo(DoFn<InputT,OutputT> doFn,
WindowingStrategy<?,?> windowingStrategy) |
DoFnInfo(DoFn<InputT,OutputT> doFn,
WindowingStrategy<?,?> windowingStrategy,
Iterable<PCollectionView<?>> sideInputViews,
Coder<InputT> inputCoder) |
| Modifier and Type | Method and Description |
|---|---|
DoFn<InputT,OutputT> |
getDoFn() |
Coder<InputT> |
getInputCoder() |
Iterable<PCollectionView<?>> |
getSideInputViews() |
WindowingStrategy<?,?> |
getWindowingStrategy() |
public DoFnInfo(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy)
public DoFnInfo(DoFn<InputT,OutputT> doFn, WindowingStrategy<?,?> windowingStrategy, Iterable<PCollectionView<?>> sideInputViews, Coder<InputT> inputCoder)
public WindowingStrategy<?,?> getWindowingStrategy()
public Iterable<PCollectionView<?>> getSideInputViews()