public class PTransformMatchers
extends java.lang.Object
PTransformMatcher
that matches PTransforms
based on the class of the
transform.
Once PTransforms
have URNs, this will be removed and replaced with a
UrnPTransformMatcher.
Modifier and Type | Method and Description |
---|---|
static PTransformMatcher |
classEqualTo(java.lang.Class<? extends PTransform> clazz)
Returns a
PTransformMatcher that matches a PTransform if the class of the
PTransform is equal to the Class provided ot this matcher. |
static PTransformMatcher |
createViewWithViewFn(java.lang.Class<? extends ViewFn> viewFnType) |
static PTransformMatcher |
emptyFlatten()
|
static PTransformMatcher |
flattenWithDuplicateInputs()
A
PTransformMatcher which matches a Flatten.PCollections which consumes a
single input PCollection multiple times. |
static PTransformMatcher |
groupIntoBatches()
A
PTransformMatcher which matches GroupIntoBatches transform. |
static PTransformMatcher |
groupWithShardableStates()
A
PTransformMatcher which matches GroupIntoBatches transform that allows
shardable states. |
static PTransformMatcher |
parDoWithFnType(java.lang.Class<? extends DoFn> fnType)
A
PTransformMatcher which matches a ParDo.SingleOutput or ParDo.MultiOutput where the DoFn is of the provided type. |
static PTransformMatcher |
requiresStableInputParDoMulti()
A
PTransformMatcher that matches a ParDo.MultiOutput containing a DoFn
that requires stable input, as signified by DoFnSignature.ProcessElementMethod.requiresStableInput() . |
static PTransformMatcher |
requiresStableInputParDoSingle()
A
PTransformMatcher that matches a ParDo.SingleOutput containing a DoFn
that requires stable input, as signified by DoFnSignature.ProcessElementMethod.requiresStableInput() . |
static PTransformMatcher |
splittableParDo()
|
static PTransformMatcher |
splittableParDoMulti()
A
PTransformMatcher that matches a ParDo.MultiOutput containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable() . |
static PTransformMatcher |
splittableParDoSingle()
A
PTransformMatcher that matches a ParDo.SingleOutput containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable() . |
static PTransformMatcher |
splittableProcessKeyedBounded()
A
PTransformMatcher that matches a ParDo.SingleOutput containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable() . |
static PTransformMatcher |
splittableProcessKeyedUnbounded()
A
PTransformMatcher that matches a ParDo.SingleOutput containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable() . |
static PTransformMatcher |
stateOrTimerParDo()
A
PTransformMatcher that matches a ParDo transform by URN and whether it
contains state or timers as specified by ParDoTranslation . |
static PTransformMatcher |
stateOrTimerParDoMulti()
A
PTransformMatcher that matches a ParDo.MultiOutput containing a DoFn
that uses state or timers, as specified by DoFnSignature.usesState() and DoFnSignature.usesTimers() . |
static PTransformMatcher |
stateOrTimerParDoSingle()
A
PTransformMatcher that matches a ParDo.SingleOutput containing a DoFn
that uses state or timers, as specified by DoFnSignature.usesState() and DoFnSignature.usesTimers() . |
static PTransformMatcher |
urnEqualTo(java.lang.String urn)
Returns a
PTransformMatcher that matches a PTransform if the URN of the PTransform is equal to the URN provided ot this matcher. |
static PTransformMatcher |
writeWithRunnerDeterminedSharding() |
public static PTransformMatcher urnEqualTo(java.lang.String urn)
PTransformMatcher
that matches a PTransform
if the URN of the PTransform
is equal to the URN provided ot this matcher.public static PTransformMatcher classEqualTo(java.lang.Class<? extends PTransform> clazz)
PTransformMatcher
that matches a PTransform
if the class of the
PTransform
is equal to the Class
provided ot this matcher.public static PTransformMatcher requiresStableInputParDoSingle()
PTransformMatcher
that matches a ParDo.SingleOutput
containing a DoFn
that requires stable input, as signified by DoFnSignature.ProcessElementMethod.requiresStableInput()
.public static PTransformMatcher requiresStableInputParDoMulti()
PTransformMatcher
that matches a ParDo.MultiOutput
containing a DoFn
that requires stable input, as signified by DoFnSignature.ProcessElementMethod.requiresStableInput()
.public static PTransformMatcher splittableParDoSingle()
PTransformMatcher
that matches a ParDo.SingleOutput
containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable()
.public static PTransformMatcher stateOrTimerParDoSingle()
PTransformMatcher
that matches a ParDo.SingleOutput
containing a DoFn
that uses state or timers, as specified by DoFnSignature.usesState()
and DoFnSignature.usesTimers()
.public static PTransformMatcher splittableParDoMulti()
PTransformMatcher
that matches a ParDo.MultiOutput
containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable()
.public static PTransformMatcher splittableParDo()
public static PTransformMatcher splittableProcessKeyedBounded()
PTransformMatcher
that matches a ParDo.SingleOutput
containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable()
.public static PTransformMatcher splittableProcessKeyedUnbounded()
PTransformMatcher
that matches a ParDo.SingleOutput
containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable()
.public static PTransformMatcher stateOrTimerParDo()
PTransformMatcher
that matches a ParDo
transform by URN and whether it
contains state or timers as specified by ParDoTranslation
.public static PTransformMatcher stateOrTimerParDoMulti()
PTransformMatcher
that matches a ParDo.MultiOutput
containing a DoFn
that uses state or timers, as specified by DoFnSignature.usesState()
and DoFnSignature.usesTimers()
.public static PTransformMatcher parDoWithFnType(java.lang.Class<? extends DoFn> fnType)
PTransformMatcher
which matches a ParDo.SingleOutput
or ParDo.MultiOutput
where the DoFn
is of the provided type.public static PTransformMatcher createViewWithViewFn(java.lang.Class<? extends ViewFn> viewFnType)
public static PTransformMatcher emptyFlatten()
public static PTransformMatcher flattenWithDuplicateInputs()
PTransformMatcher
which matches a Flatten.PCollections
which consumes a
single input PCollection
multiple times.public static PTransformMatcher groupIntoBatches()
PTransformMatcher
which matches GroupIntoBatches
transform.public static PTransformMatcher groupWithShardableStates()
PTransformMatcher
which matches GroupIntoBatches
transform that allows
shardable states.public static PTransformMatcher writeWithRunnerDeterminedSharding()