public static class PAssert.OneSideInputAssert<ActualT> extends PTransform<PBegin,PDone> implements java.io.Serializable
PCollectionView<ActualT>and an assertion over
ActualT, and checks it within a Beam pipeline.
Note that the entire assertion must be serializable.
This is generally useful for assertion functions that are serializable but whose underlying data may not have a coder.
|Modifier and Type||Method and Description|
Override this method to specify how this
compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate
public PDone expand(PBegin input)
PTransformshould be expanded on the given
NOTE: This method should not be called directly. Instead apply the
be applied to the
InputT using the
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).