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:

• 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	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<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

Methods inherited from class java.lang.Object

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

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,List<TimestampedValue<OutputT>>>>.ProcessContext c,
 RestrictionTracker<org.apache.beam.sdk.transforms.Watch.GrowthState,KV<Watch.Growth.PollResult<OutputT>,TerminationStateT>> tracker,
 ManualWatermarkEstimator<Instant> watermarkEstimator)
                                 throws Exception

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()