@Experimental(value=CORE_RUNNERS_ONLY) public class PTransformMatchers extends 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(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(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 |
parDoWithFnType(Class<? extends DoFn> fnType)
A
PTransformMatcher which matches a ParDo.SingleOutput or ParDo.MultiOutput where the DoFn is of the provided type. |
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 |
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 |
writeWithRunnerDeterminedSharding() |
public static PTransformMatcher classEqualTo(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 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 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(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(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 writeWithRunnerDeterminedSharding()
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.