Class DoFnSignature
- java.lang.Object
-
- org.apache.beam.sdk.transforms.reflect.DoFnSignature
-
@Internal public abstract class DoFnSignature extends java.lang.Object
Describes the signature of aDoFn
, in particular, which features it uses, which extra context it requires, types of the input and output elements, etc.See A new DoFn.
-
-
Nested Class Summary
-
Constructor Summary
Constructors Constructor Description DoFnSignature()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description abstract @Nullable java.util.Map<java.lang.String,DoFnSignature.FieldAccessDeclaration>
fieldAccessDeclarations()
Field access declaration.abstract @Nullable DoFnSignature.BundleMethod
finishBundle()
Details about thisDoFn
'sDoFn.FinishBundle
method.abstract java.lang.Class<? extends DoFn<?,?>>
fnClass()
Class of the originalDoFn
from which this signature was produced.abstract @Nullable DoFnSignature.GetInitialRestrictionMethod
getInitialRestriction()
Details about thisDoFn
'sDoFn.GetInitialRestriction
method.abstract @Nullable DoFnSignature.GetInitialWatermarkEstimatorStateMethod
getInitialWatermarkEstimatorState()
Details about thisDoFn
'sDoFn.GetInitialWatermarkEstimatorState
method.abstract @Nullable DoFnSignature.GetRestrictionCoderMethod
getRestrictionCoder()
Details about thisDoFn
'sDoFn.GetRestrictionCoder
method.abstract @Nullable DoFnSignature.GetSizeMethod
getSize()
Details about thisDoFn
'sDoFn.GetSize
method.abstract @Nullable DoFnSignature.GetWatermarkEstimatorStateCoderMethod
getWatermarkEstimatorStateCoder()
Details about thisDoFn
'sDoFn.GetWatermarkEstimatorStateCoder
method.abstract PCollection.IsBounded
isBoundedPerElement()
Whether thisDoFn
does a bounded amount of work per element.boolean
isStateful()
Deprecated.useusesState()
, it's cleanerabstract @Nullable DoFnSignature.NewTrackerMethod
newTracker()
Details about thisDoFn
'sDoFn.NewTracker
method.abstract @Nullable DoFnSignature.NewWatermarkEstimatorMethod
newWatermarkEstimator()
Details about thisDoFn
'sDoFn.NewWatermarkEstimator
method.abstract @Nullable java.util.Map<java.lang.String,DoFnSignature.OnTimerFamilyMethod>
onTimerFamilyMethods()
Details about thisDoFn
'sDoFn.OnTimerFamily
methods.abstract @Nullable java.util.Map<java.lang.String,DoFnSignature.OnTimerMethod>
onTimerMethods()
Details about thisDoFn
'sDoFn.OnTimer
methods.abstract @Nullable DoFnSignature.OnWindowExpirationMethod
onWindowExpiration()
Details about thisDoFn
'sDoFn.OnWindowExpiration
method.abstract DoFnSignature.ProcessElementMethod
processElement()
Details about thisDoFn
'sDoFn.ProcessElement
method.abstract @Nullable DoFnSignature.LifecycleMethod
setup()
Details about thisDoFn
'sDoFn.Setup
method.abstract @Nullable DoFnSignature.SplitRestrictionMethod
splitRestriction()
Details about thisDoFn
'sDoFn.SplitRestriction
method.abstract @Nullable DoFnSignature.BundleMethod
startBundle()
Details about thisDoFn
'sDoFn.StartBundle
method.abstract java.util.Map<java.lang.String,DoFnSignature.StateDeclaration>
stateDeclarations()
Details about the state cells that thisDoFn
declares.abstract @Nullable DoFnSignature.LifecycleMethod
teardown()
Details about thisDoFn
'sDoFn.Teardown
method.abstract java.util.Map<java.lang.String,DoFnSignature.TimerDeclaration>
timerDeclarations()
Timer declarations present on theDoFn
class.abstract java.util.Map<java.lang.String,DoFnSignature.TimerFamilyDeclaration>
timerFamilyDeclarations()
TimerMap declarations present on theDoFn
class.abstract @Nullable DoFnSignature.TruncateRestrictionMethod
truncateRestriction()
Details about thisDoFn
'sDoFn.TruncateRestriction
method.boolean
usesState()
Whether theDoFn
described by this signature uses state.boolean
usesTimers()
Whether theDoFn
described by this signature uses timers.
-
-
-
Method Detail
-
fnClass
public abstract java.lang.Class<? extends DoFn<?,?>> fnClass()
Class of the originalDoFn
from which this signature was produced.
-
isBoundedPerElement
public abstract PCollection.IsBounded isBoundedPerElement()
Whether thisDoFn
does a bounded amount of work per element.
-
processElement
public abstract DoFnSignature.ProcessElementMethod processElement()
Details about thisDoFn
'sDoFn.ProcessElement
method.
-
stateDeclarations
public abstract java.util.Map<java.lang.String,DoFnSignature.StateDeclaration> stateDeclarations()
Details about the state cells that thisDoFn
declares. Immutable.
-
startBundle
public abstract @Nullable DoFnSignature.BundleMethod startBundle()
Details about thisDoFn
'sDoFn.StartBundle
method.
-
finishBundle
public abstract @Nullable DoFnSignature.BundleMethod finishBundle()
Details about thisDoFn
'sDoFn.FinishBundle
method.
-
setup
public abstract @Nullable DoFnSignature.LifecycleMethod setup()
Details about thisDoFn
'sDoFn.Setup
method.
-
teardown
public abstract @Nullable DoFnSignature.LifecycleMethod teardown()
Details about thisDoFn
'sDoFn.Teardown
method.
-
onWindowExpiration
public abstract @Nullable DoFnSignature.OnWindowExpirationMethod onWindowExpiration()
Details about thisDoFn
'sDoFn.OnWindowExpiration
method.
-
timerDeclarations
public abstract java.util.Map<java.lang.String,DoFnSignature.TimerDeclaration> timerDeclarations()
Timer declarations present on theDoFn
class. Immutable.
-
timerFamilyDeclarations
public abstract java.util.Map<java.lang.String,DoFnSignature.TimerFamilyDeclaration> timerFamilyDeclarations()
TimerMap declarations present on theDoFn
class. Immutable.
-
fieldAccessDeclarations
public abstract @Nullable java.util.Map<java.lang.String,DoFnSignature.FieldAccessDeclaration> fieldAccessDeclarations()
Field access declaration.
-
getInitialRestriction
public abstract @Nullable DoFnSignature.GetInitialRestrictionMethod getInitialRestriction()
Details about thisDoFn
'sDoFn.GetInitialRestriction
method.
-
splitRestriction
public abstract @Nullable DoFnSignature.SplitRestrictionMethod splitRestriction()
Details about thisDoFn
'sDoFn.SplitRestriction
method.
-
truncateRestriction
public abstract @Nullable DoFnSignature.TruncateRestrictionMethod truncateRestriction()
Details about thisDoFn
'sDoFn.TruncateRestriction
method.
-
getRestrictionCoder
public abstract @Nullable DoFnSignature.GetRestrictionCoderMethod getRestrictionCoder()
Details about thisDoFn
'sDoFn.GetRestrictionCoder
method.
-
getWatermarkEstimatorStateCoder
public abstract @Nullable DoFnSignature.GetWatermarkEstimatorStateCoderMethod getWatermarkEstimatorStateCoder()
Details about thisDoFn
'sDoFn.GetWatermarkEstimatorStateCoder
method.
-
getInitialWatermarkEstimatorState
public abstract @Nullable DoFnSignature.GetInitialWatermarkEstimatorStateMethod getInitialWatermarkEstimatorState()
Details about thisDoFn
'sDoFn.GetInitialWatermarkEstimatorState
method.
-
newWatermarkEstimator
public abstract @Nullable DoFnSignature.NewWatermarkEstimatorMethod newWatermarkEstimator()
Details about thisDoFn
'sDoFn.NewWatermarkEstimator
method.
-
newTracker
public abstract @Nullable DoFnSignature.NewTrackerMethod newTracker()
Details about thisDoFn
'sDoFn.NewTracker
method.
-
getSize
public abstract @Nullable DoFnSignature.GetSizeMethod getSize()
Details about thisDoFn
'sDoFn.GetSize
method.
-
onTimerMethods
public abstract @Nullable java.util.Map<java.lang.String,DoFnSignature.OnTimerMethod> onTimerMethods()
Details about thisDoFn
'sDoFn.OnTimer
methods.
-
onTimerFamilyMethods
public abstract @Nullable java.util.Map<java.lang.String,DoFnSignature.OnTimerFamilyMethod> onTimerFamilyMethods()
Details about thisDoFn
'sDoFn.OnTimerFamily
methods.
-
isStateful
@Deprecated public boolean isStateful()
Deprecated.useusesState()
, it's cleaner
-
usesState
public boolean usesState()
Whether theDoFn
described by this signature uses state.
-
usesTimers
public boolean usesTimers()
Whether theDoFn
described by this signature uses timers.
-
-