org.apache.beam.sdk.transforms

Class Watch.WatchGrowthFn<InputT,OutputT,KeyT,TerminationStateT>

java.lang.Object

org.apache.beam.sdk.transforms.DoFn<InputT,KV<InputT,java.util.List<TimestampedValue<OutputT>>>>

org.apache.beam.sdk.transforms.Watch.WatchGrowthFn<InputT,OutputT,KeyT,TerminationStateT>

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

Enclosing class:

Watch

@DoFn.UnboundedPerElement
protected static class Watch.WatchGrowthFn<InputT,OutputT,KeyT,TerminationStateT>
extends DoFn<InputT,KV<InputT,java.util.List<TimestampedValue<OutputT>>>>

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

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.transforms.Watch.GrowthState	getInitialRestriction(InputT element)
Instant	getInitialWatermarkEstimatorState(Instant currentElementTimestamp)
Coder<org.apache.beam.sdk.transforms.Watch.GrowthState>	getRestrictionCoder()
org.apache.beam.sdk.transforms.Watch.GrowthTracker<OutputT,TerminationStateT>	newTracker(org.apache.beam.sdk.transforms.Watch.GrowthState restriction)
WatermarkEstimators.Manual	newWatermarkEstimator(Instant watermarkEstimatorState)
DoFn.ProcessContinuation	process(DoFn.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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInitialWatermarkEstimatorState

@DoFn.GetInitialWatermarkEstimatorState
public Instant getInitialWatermarkEstimatorState(@DoFn.Timestamp
                                                                                         Instant currentElementTimestamp)

newWatermarkEstimator

@DoFn.NewWatermarkEstimator
public WatermarkEstimators.Manual newWatermarkEstimator(@DoFn.WatermarkEstimatorState
                                                                                    Instant watermarkEstimatorState)

process

@DoFn.ProcessElement
public DoFn.ProcessContinuation process(DoFn.ProcessContext c,
                                                             RestrictionTracker<org.apache.beam.sdk.transforms.Watch.GrowthState,KV<Watch.Growth.PollResult<OutputT>,TerminationStateT>> tracker,
                                                             ManualWatermarkEstimator<Instant> watermarkEstimator)
                                                      throws java.lang.Exception

Throws:

java.lang.Exception

getInitialRestriction

@DoFn.GetInitialRestriction
public org.apache.beam.sdk.transforms.Watch.GrowthState getInitialRestriction(@DoFn.Element
                                                                                                          InputT element)

newTracker

@DoFn.NewTracker
public org.apache.beam.sdk.transforms.Watch.GrowthTracker<OutputT,TerminationStateT> newTracker(@DoFn.Restriction
                                                                                                                 org.apache.beam.sdk.transforms.Watch.GrowthState restriction)

getRestrictionCoder

@DoFn.GetRestrictionCoder
public Coder<org.apache.beam.sdk.transforms.Watch.GrowthState> getRestrictionCoder()