Package org.apache.beam.sdk.transforms
Class Watch.WatchGrowthFn<InputT,OutputT,KeyT,TerminationStateT>
java.lang.Object
org.apache.beam.sdk.transforms.DoFn<InputT,KV<InputT,List<TimestampedValue<OutputT>>>>
org.apache.beam.sdk.transforms.Watch.WatchGrowthFn<InputT,OutputT,KeyT,TerminationStateT>
- All Implemented Interfaces:
Serializable
,HasDisplayData
- Enclosing class:
Watch
@UnboundedPerElement
protected static class Watch.WatchGrowthFn<InputT,OutputT,KeyT,TerminationStateT>
extends DoFn<InputT,KV<InputT,List<TimestampedValue<OutputT>>>>
- See Also:
-
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
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.beam.sdk.transforms.Watch.GrowthState
getInitialRestriction
(InputT element) getInitialWatermarkEstimatorState
(Instant currentElementTimestamp) Coder
<org.apache.beam.sdk.transforms.Watch.GrowthState> org.apache.beam.sdk.transforms.Watch.GrowthTracker
<OutputT, TerminationStateT> newTracker
(org.apache.beam.sdk.transforms.Watch.GrowthState restriction) newWatermarkEstimator
(Instant watermarkEstimatorState) process
(DoFn<InputT, KV<InputT, List<TimestampedValue<OutputT>>>>.ProcessContext c, RestrictionTracker<org.apache.beam.sdk.transforms.Watch.GrowthState, KV<Watch.Growth.PollResult<OutputT>, TerminationStateT>> tracker, ManualWatermarkEstimator<Instant> watermarkEstimator) Methods inherited from class org.apache.beam.sdk.transforms.DoFn
getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing
-
Method Details
-
getInitialWatermarkEstimatorState
@GetInitialWatermarkEstimatorState public Instant getInitialWatermarkEstimatorState(@Timestamp Instant currentElementTimestamp) -
newWatermarkEstimator
@NewWatermarkEstimator public WatermarkEstimators.Manual newWatermarkEstimator(@WatermarkEstimatorState Instant watermarkEstimatorState) -
process
@ProcessElement public DoFn.ProcessContinuation process(DoFn<InputT, KV<InputT, throws ExceptionList<TimestampedValue<OutputT>>>>.ProcessContext c, RestrictionTracker<org.apache.beam.sdk.transforms.Watch.GrowthState, KV<Watch.Growth.PollResult<OutputT>, TerminationStateT>> tracker, ManualWatermarkEstimator<Instant> watermarkEstimator) - Throws:
Exception
-
getInitialRestriction
@GetInitialRestriction public org.apache.beam.sdk.transforms.Watch.GrowthState getInitialRestriction(@Element InputT element) -
newTracker
@NewTracker public org.apache.beam.sdk.transforms.Watch.GrowthTracker<OutputT,TerminationStateT> newTracker(@Restriction org.apache.beam.sdk.transforms.Watch.GrowthState restriction) -
getRestrictionCoder
@GetRestrictionCoder public Coder<org.apache.beam.sdk.transforms.Watch.GrowthState> getRestrictionCoder()
-