Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.transforms
Class IntraBundleParallelization.Unbound
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.transforms.IntraBundleParallelization.Unbound
-
- Enclosing class:
- IntraBundleParallelization
public static class IntraBundleParallelization.Unbound extends Object
An incompleteIntraBundleParallelization
transform, with unbound input/output types.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/output types of thisPTransform
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description <InputT,OutputT>
IntraBundleParallelization.Bound<InputT,OutputT>of(DoFn<InputT,OutputT> doFn)
IntraBundleParallelization.Unbound
withMaxParallelism(int maxParallelism)
Returns a newIntraBundleParallelization
PTransform
like this one with the specified maximum concurrency level.
-
-
-
Method Detail
-
withMaxParallelism
public IntraBundleParallelization.Unbound withMaxParallelism(int maxParallelism)
Returns a newIntraBundleParallelization
PTransform
like this one with the specified maximum concurrency level.
-
of
public <InputT,OutputT> IntraBundleParallelization.Bound<InputT,OutputT> of(DoFn<InputT,OutputT> doFn)
Returns a newIntraBundleParallelization
PTransform
like this one with the specifiedDoFn
.Note that the specified
doFn
needs to be thread safe.
-
-