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: