Google Cloud Dataflow SDK for Java, version 1.9.1
Class ParDo.UnboundMulti<OutputT>
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.transforms.ParDo.UnboundMulti<OutputT>
-
- Type Parameters:
OutputT
- the type of the main outputPCollection
elements
- Enclosing class:
- ParDo
public static class ParDo.UnboundMulti<OutputT> extends Object
An incomplete multi-outputParDo
transform, with unbound input type.Before being applied,
of(com.google.cloud.dataflow.sdk.transforms.DoFn<InputT, OutputT>)
must be invoked to specify theDoFn
to invoke, which will also bind the input type of thisPTransform
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description ParDo.UnboundMulti<OutputT>
named(String name)
Returns a new multi-outputParDo
transform that's like this transform but with the specified name.<InputT> ParDo.BoundMulti<InputT,OutputT>
of(DoFn<InputT,OutputT> fn)
Returns a new multi-outputParDo
PTransform
that's like this transform but that will invoke the givenDoFn
function, and that has its input type bound.<InputT> ParDo.BoundMulti<InputT,OutputT>
of(DoFn<InputT,OutputT> fn, Class<?> fnClass)
<InputT> ParDo.BoundMulti<InputT,OutputT>
of(DoFnWithContext<InputT,OutputT> fn)
Returns a new multi-outputParDo
PTransform
that's like this transform but which will invoke the givenDoFnWithContext
function, and which has its input type bound.ParDo.UnboundMulti<OutputT>
withSideInputs(Iterable<? extends PCollectionView<?>> sideInputs)
Returns a new multi-outputParDo
transform that's like this transform but with the specified additional side inputs.ParDo.UnboundMulti<OutputT>
withSideInputs(PCollectionView<?>... sideInputs)
Returns a new multi-outputParDo
transform that's like this transform but with the specified side inputs.
-
-
-
Method Detail
-
named
public ParDo.UnboundMulti<OutputT> named(String name)
Returns a new multi-outputParDo
transform that's like this transform but with the specified name. Does not modify this transform. The resulting transform is still incomplete.See the discussion of Naming above for more explanation.
-
withSideInputs
public ParDo.UnboundMulti<OutputT> withSideInputs(PCollectionView<?>... sideInputs)
Returns a new multi-outputParDo
transform that's like this transform but with the specified side inputs. Does not modify this transform. The resulting transform is still incomplete.See the discussion of Side Inputs above and on
ParDo.withSideInputs(com.google.cloud.dataflow.sdk.values.PCollectionView<?>...)
for more explanation.
-
withSideInputs
public ParDo.UnboundMulti<OutputT> withSideInputs(Iterable<? extends PCollectionView<?>> sideInputs)
Returns a new multi-outputParDo
transform that's like this transform but with the specified additional side inputs. Does not modify this transform. The resulting transform is still incomplete.See the discussion of Side Inputs above and on
ParDo.withSideInputs(com.google.cloud.dataflow.sdk.values.PCollectionView<?>...)
for more explanation.
-
of
public <InputT> ParDo.BoundMulti<InputT,OutputT> of(DoFn<InputT,OutputT> fn)
Returns a new multi-outputParDo
PTransform
that's like this transform but that will invoke the givenDoFn
function, and that has its input type bound. Does not modify this transform. The resultingPTransform
is sufficiently specified to be applied, but more properties can still be specified.
-
of
public <InputT> ParDo.BoundMulti<InputT,OutputT> of(DoFn<InputT,OutputT> fn, Class<?> fnClass)
-
of
public <InputT> ParDo.BoundMulti<InputT,OutputT> of(DoFnWithContext<InputT,OutputT> fn)
Returns a new multi-outputParDo
PTransform
that's like this transform but which will invoke the givenDoFnWithContext
function, and which has its input type bound. Does not modify this transform. The resultingPTransform
is sufficiently specified to be applied, but more properties can still be specified.
-
-