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

@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	Description
org.apache.beam.sdk.transforms.Watch.GrowthState	getInitialRestriction(InputT element)
org.joda.time.Instant	getInitialWatermarkEstimatorState(org.joda.time.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(org.joda.time.Instant watermarkEstimatorState)
DoFn.ProcessContinuation	process(DoFn.ProcessContext c, RestrictionTracker<org.apache.beam.sdk.transforms.Watch.GrowthState,KV<Watch.Growth.PollResult<OutputT>,TerminationStateT>> tracker, ManualWatermarkEstimator<org.joda.time.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

@GetInitialWatermarkEstimatorState
public org.joda.time.Instant getInitialWatermarkEstimatorState(@Timestamp
                                                               org.joda.time.Instant currentElementTimestamp)

newWatermarkEstimator

@NewWatermarkEstimator
public WatermarkEstimators.Manual newWatermarkEstimator(@WatermarkEstimatorState
                                                        org.joda.time.Instant watermarkEstimatorState)

process

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

Throws:

java.lang.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()