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

Class DoFnSignature.NewWatermarkEstimatorMethod

java.lang.Object

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

All Implemented Interfaces:

DoFnSignature.DoFnMethod, DoFnSignature.MethodWithExtraParameters

Enclosing class:

DoFnSignature

public abstract static class DoFnSignature.NewWatermarkEstimatorMethod
extends java.lang.Object
implements DoFnSignature.MethodWithExtraParameters

Describes a DoFn.NewWatermarkEstimator method.

Constructor Summary

Constructors

Constructor	Description
NewWatermarkEstimatorMethod()

Method Summary

Modifier and Type	Method	Description
abstract java.util.List<DoFnSignature.Parameter>	extraParameters()	Types of optional parameters of the annotated method, in the order they appear.
abstract java.lang.reflect.Method	targetMethod()	The annotated method itself.
abstract TypeDescriptor<?>	watermarkEstimatorT()	Type of the returned WatermarkEstimator.
abstract @Nullable TypeDescriptor<? extends BoundedWindow>	windowT()	The window type used by this method, if any.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.transforms.reflect.DoFnSignature.MethodWithExtraParameters

observesWindow

Constructor Detail

NewWatermarkEstimatorMethod

public NewWatermarkEstimatorMethod()

Method Detail

targetMethod

public abstract java.lang.reflect.Method targetMethod()

The annotated method itself.

Specified by:

targetMethod in interface DoFnSignature.DoFnMethod

watermarkEstimatorT

public abstract TypeDescriptor<?> watermarkEstimatorT()

Type of the returned WatermarkEstimator.

windowT

public abstract @Nullable TypeDescriptor<? extends BoundedWindow> windowT()

The window type used by this method, if any.

Specified by:

windowT in interface DoFnSignature.MethodWithExtraParameters

extraParameters

public abstract java.util.List<DoFnSignature.Parameter> extraParameters()

Types of optional parameters of the annotated method, in the order they appear.

Specified by:

extraParameters in interface DoFnSignature.MethodWithExtraParameters