public abstract static class DoFnSignature.ProcessElementMethod extends java.lang.Object implements DoFnSignature.MethodWithExtraParameters
DoFn.ProcessElement
method.Constructor and Description |
---|
ProcessElementMethod() |
Modifier and Type | Method and Description |
---|---|
abstract java.util.List<DoFnSignature.Parameter> |
extraParameters()
Types of optional parameters of the annotated method, in the order they appear.
|
@Nullable DoFnSignature.Parameter.OutputReceiverParameter |
getMainOutputReceiver()
The
DoFnSignature.Parameter.OutputReceiverParameter for a main output, or null if there is none. |
@Nullable java.util.List<DoFnSignature.Parameter.SchemaElementParameter> |
getSchemaElementParameters() |
@Nullable java.util.List<DoFnSignature.Parameter.SideInputParameter> |
getSideInputParameters() |
abstract boolean |
hasReturnValue()
Whether this
DoFn returns a DoFn.ProcessContinuation or void. |
boolean |
isSplittable()
Whether this
DoFn is splittable. |
abstract boolean |
requiresStableInput()
Whether this method requires stable input, expressed via
DoFn.RequiresStableInput . |
abstract boolean |
requiresTimeSortedInput()
Whether this method requires time sorted input, expressed via
DoFn.RequiresTimeSortedInput . |
abstract java.lang.reflect.Method |
targetMethod()
The annotated method itself.
|
abstract @Nullable TypeDescriptor<?> |
trackerT()
Concrete type of the
RestrictionTracker parameter, if present. |
abstract @Nullable TypeDescriptor<?> |
watermarkEstimatorT()
Concrete type of the
WatermarkEstimator parameter, if present. |
abstract @Nullable TypeDescriptor<? extends BoundedWindow> |
windowT()
The window type used by this method, if any.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
observesWindow
public abstract java.lang.reflect.Method targetMethod()
targetMethod
in interface DoFnSignature.DoFnMethod
public abstract java.util.List<DoFnSignature.Parameter> extraParameters()
extraParameters
in interface DoFnSignature.MethodWithExtraParameters
public abstract boolean requiresStableInput()
DoFn.RequiresStableInput
.public abstract boolean requiresTimeSortedInput()
DoFn.RequiresTimeSortedInput
.public abstract @Nullable TypeDescriptor<?> trackerT()
RestrictionTracker
parameter, if present.public abstract @Nullable TypeDescriptor<?> watermarkEstimatorT()
WatermarkEstimator
parameter, if present.public abstract @Nullable TypeDescriptor<? extends BoundedWindow> windowT()
windowT
in interface DoFnSignature.MethodWithExtraParameters
public abstract boolean hasReturnValue()
DoFn
returns a DoFn.ProcessContinuation
or void.public @Nullable java.util.List<DoFnSignature.Parameter.SchemaElementParameter> getSchemaElementParameters()
public @Nullable java.util.List<DoFnSignature.Parameter.SideInputParameter> getSideInputParameters()
public @Nullable DoFnSignature.Parameter.OutputReceiverParameter getMainOutputReceiver()
DoFnSignature.Parameter.OutputReceiverParameter
for a main output, or null if there is none.public boolean isSplittable()
DoFn
is splittable.