public class SplittableParDoNaiveBounded
extends java.lang.Object
SplittableParDo.ProcessKeyedElements
using a simple Reshuffle
and ParDo
.Modifier and Type | Class and Description |
---|---|
static class |
SplittableParDoNaiveBounded.NaiveProcessFn<InputT,OutputT,RestrictionT,PositionT,WatermarkEstimatorStateT> |
static class |
SplittableParDoNaiveBounded.OverrideFactory<InputT,OutputT,RestrictionT,WatermarkEstimatorStateT>
Overrides a
SplittableParDo.ProcessKeyedElements into SplittableProcessNaive . |
Constructor and Description |
---|
SplittableParDoNaiveBounded() |