Package org.apache.beam.sdk.transforms.reflect

Class DoFnSignature.Parameter.WatermarkEstimatorParameter

java.lang.Object

org.apache.beam.sdk.transforms.reflect.DoFnSignature.Parameter

org.apache.beam.sdk.transforms.reflect.DoFnSignature.Parameter.WatermarkEstimatorParameter

Enclosing class:

DoFnSignature.Parameter

public abstract static class DoFnSignature.Parameter.WatermarkEstimatorParameter
extends DoFnSignature.Parameter

Descriptor for a DoFnSignature.Parameter of type DoFn.WatermarkEstimatorState.

All such descriptors are equal.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.reflect.DoFnSignature.Parameter

DoFnSignature.Parameter.BundleFinalizerParameter, DoFnSignature.Parameter.Cases<ResultT>, DoFnSignature.Parameter.ElementParameter, DoFnSignature.Parameter.FinishBundleContextParameter, DoFnSignature.Parameter.KeyParameter, DoFnSignature.Parameter.OnTimerContextParameter, DoFnSignature.Parameter.OnWindowExpirationContextParameter, DoFnSignature.Parameter.OutputReceiverParameter, DoFnSignature.Parameter.PaneInfoParameter, DoFnSignature.Parameter.PipelineOptionsParameter, DoFnSignature.Parameter.ProcessContextParameter, DoFnSignature.Parameter.RestrictionParameter, DoFnSignature.Parameter.RestrictionTrackerParameter, DoFnSignature.Parameter.SchemaElementParameter, DoFnSignature.Parameter.SideInputParameter, DoFnSignature.Parameter.StartBundleContextParameter, DoFnSignature.Parameter.StateParameter, DoFnSignature.Parameter.TaggedOutputReceiverParameter, DoFnSignature.Parameter.TimeDomainParameter, DoFnSignature.Parameter.TimerFamilyParameter, DoFnSignature.Parameter.TimerIdParameter, DoFnSignature.Parameter.TimerParameter, DoFnSignature.Parameter.TimestampParameter, DoFnSignature.Parameter.WatermarkEstimatorParameter, DoFnSignature.Parameter.WatermarkEstimatorStateParameter, DoFnSignature.Parameter.WindowParameter

Method Summary

Modifier and Type	Method	Description
abstract TypeDescriptor<?>	estimatorT()

Methods inherited from class org.apache.beam.sdk.transforms.reflect.DoFnSignature.Parameter

boundedWindow, bundleFinalizer, elementParameter, finishBundleContext, keyT, match, onTimerContext, onWindowExpirationContext, outputReceiverParameter, paneInfoParameter, pipelineOptions, processContext, restrictionParameter, restrictionTracker, schemaElementParameter, sideInputParameter, startBundleContext, stateParameter, taggedOutputReceiverParameter, timeDomainParameter, timerFamilyParameter, timerIdParameter, timerParameter, timestampParameter, watermarkEstimator, watermarkEstimatorState

Methods inherited from class java.lang.Object

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

Method Detail

estimatorT

public abstract TypeDescriptor<?> estimatorT()