Package org.apache.beam.sdk.transforms
Class Reshuffle.AssignShardFn<T>
- java.lang.Object
-
- org.apache.beam.sdk.transforms.DoFn<T,KV<java.lang.Integer,T>>
-
- org.apache.beam.sdk.transforms.Reshuffle.AssignShardFn<T>
-
- All Implemented Interfaces:
java.io.Serializable
,HasDisplayData
public static class Reshuffle.AssignShardFn<T> extends DoFn<T,KV<java.lang.Integer,T>>
- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.DoFn
DoFn.AlwaysFetched, DoFn.BoundedPerElement, DoFn.BundleFinalizer, DoFn.Element, DoFn.FieldAccess, DoFn.FinishBundle, DoFn.FinishBundleContext, DoFn.GetInitialRestriction, DoFn.GetInitialWatermarkEstimatorState, DoFn.GetRestrictionCoder, DoFn.GetSize, DoFn.GetWatermarkEstimatorStateCoder, DoFn.Key, DoFn.MultiOutputReceiver, DoFn.NewTracker, DoFn.NewWatermarkEstimator, DoFn.OnTimer, DoFn.OnTimerContext, DoFn.OnTimerFamily, DoFn.OnWindowExpiration, DoFn.OnWindowExpirationContext, DoFn.OutputReceiver<T>, DoFn.ProcessContext, DoFn.ProcessContinuation, DoFn.ProcessElement, DoFn.RequiresStableInput, DoFn.RequiresTimeSortedInput, DoFn.Restriction, DoFn.Setup, DoFn.SideInput, DoFn.SplitRestriction, DoFn.StartBundle, DoFn.StartBundleContext, DoFn.StateId, DoFn.Teardown, DoFn.TimerFamily, DoFn.TimerId, DoFn.Timestamp, DoFn.TruncateRestriction, DoFn.UnboundedPerElement, DoFn.WatermarkEstimatorState, DoFn.WindowedContext
-
-
Constructor Summary
Constructors Constructor Description AssignShardFn(@Nullable java.lang.Integer numBuckets)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
processElement(T element, DoFn.OutputReceiver<KV<java.lang.Integer,T>> r)
void
setup()
-
Methods inherited from class org.apache.beam.sdk.transforms.DoFn
getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing
-
-
-
-
Method Detail
-
setup
@Setup public void setup()
-
processElement
@ProcessElement public void processElement(@Element T element, DoFn.OutputReceiver<KV<java.lang.Integer,T>> r)
-
-