Package org.apache.beam.sdk.testing

Class PAssert.PCollectionListContentsAssert<T>

java.lang.Object

org.apache.beam.sdk.testing.PAssert.PCollectionListContentsAssert<T>

Enclosing class:

PAssert

protected static class PAssert.PCollectionListContentsAssert<T>
extends Object

An assert about the contents of each PCollection in the given PCollectionList.

Constructor Summary

Constructors

Constructor	Description
PCollectionListContentsAssert(PCollectionList<T> actual)

Method Summary

Modifier and Type	Method	Description
PAssert.PCollectionListContentsAssert<T>	satisfies(List<SerializableFunction<Iterable<T>,Void>> checkerFnList)	Takes list of SerializableFunctions of the same size as pCollectionList, and applies each matcher to the PCollection with the identical index in the pCollectionList.
PAssert.PCollectionListContentsAssert<T>	satisfies(SerializableFunction<Iterable<T>,Void> checkerFn)	Applies one SerializableFunction to check the elements of each PCollection in the PCollectionList.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PCollectionListContentsAssert

public PCollectionListContentsAssert(PCollectionList<T> actual)

Method Details

satisfies

public PAssert.PCollectionListContentsAssert<T> satisfies(SerializableFunction<Iterable<T>,Void> checkerFn)

Applies one SerializableFunction to check the elements of each PCollection in the PCollectionList.

Returns this PCollectionListContentsAssert.

satisfies

public PAssert.PCollectionListContentsAssert<T> satisfies(List<SerializableFunction<Iterable<T>,Void>> checkerFnList)

Takes list of SerializableFunctions of the same size as pCollectionList, and applies each matcher to the PCollection with the identical index in the pCollectionList.

Returns this PCollectionListContentsAssert.