Package org.apache.beam.sdk.testing

Class PAssert.PCollectionContentsAssert<T>

java.lang.Object

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

All Implemented Interfaces:

PAssert.IterableAssert<T>

Enclosing class:

PAssert

protected static class PAssert.PCollectionContentsAssert<T>
extends Object
implements PAssert.IterableAssert<T>

An PAssert.IterableAssert about the contents of a PCollection. This does not require the runner to support side inputs.

Constructor Summary

Constructors

Constructor	Description
PCollectionContentsAssert(PCollection<T> actual, org.apache.beam.sdk.testing.PAssert.AssertionWindows rewindowingStrategy, SimpleFunction<Iterable<ValueInSingleWindow<T>>,Iterable<T>> paneExtractor, PAssert.PAssertionSite site)
PCollectionContentsAssert(PCollection<T> actual, PAssert.PAssertionSite site)

Method Summary

Modifier and Type	Method	Description
PAssert.PCollectionContentsAssert<T>	containsInAnyOrder()	Asserts that the iterable in question is empty.
PAssert.PCollectionContentsAssert<T>	containsInAnyOrder(Iterable<T> expectedElements)	Checks that the Iterable contains the expected elements, in any order.
final PAssert.PCollectionContentsAssert<T>	containsInAnyOrder(SerializableMatcher<? super T>... elementMatchers)	Checks that the Iterable contains elements that match the provided matchers, in any order.
final PAssert.PCollectionContentsAssert<T>	containsInAnyOrder(T... expectedElements)	Checks that the Iterable contains the expected elements, in any order.
PAssert.PCollectionContentsAssert<T>	empty()	Asserts that the iterable in question is empty.
boolean	equals(@Nullable Object o)	Deprecated. Object.equals(Object) is not supported on PAssert objects.
int	hashCode()	Deprecated. Object.hashCode() is not supported on PAssert objects.
PAssert.PCollectionContentsAssert<T>	inCombinedNonLatePanes(BoundedWindow window)	Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window across all panes that were not produced by the arrival of late data.
PAssert.IterableAssert<T>	inEarlyGlobalWindowPanes()	Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on panes in the GlobalWindow that were emitted before the GlobalWindow closed.
PAssert.PCollectionContentsAssert<T>	inEarlyPane(BoundedWindow window)	Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window across all panes that were produced by the arrival of early data.
PAssert.PCollectionContentsAssert<T>	inFinalPane(BoundedWindow window)	Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window, running the checker only on the final pane for each key.
PAssert.PCollectionContentsAssert<T>	inLatePane(BoundedWindow window)	Creates a new PAssert.IterableAssert with the assertion restricted to only run on the provided window across all panes that were produced by the arrival of late data.
PAssert.PCollectionContentsAssert<T>	inOnlyPane(BoundedWindow window)	Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window.
PAssert.PCollectionContentsAssert<T>	inOnTimePane(BoundedWindow window)	Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window.
PAssert.PCollectionContentsAssert<T>	inWindow(BoundedWindow window)	Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window.
PAssert.PCollectionContentsAssert<T>	satisfies(SerializableFunction<Iterable<T>,Void> checkerFn)	Applies the provided checking function (presumably containing assertions) to the iterable in question.

Methods inherited from class java.lang.Object

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

Constructor Details

PCollectionContentsAssert

public PCollectionContentsAssert(PCollection<T> actual,
 PAssert.PAssertionSite site)

PCollectionContentsAssert

public PCollectionContentsAssert(PCollection<T> actual,
 org.apache.beam.sdk.testing.PAssert.AssertionWindows rewindowingStrategy,
 SimpleFunction<Iterable<ValueInSingleWindow<T>>,Iterable<T>> paneExtractor,
 PAssert.PAssertionSite site)

Method Details

inWindow

public PAssert.PCollectionContentsAssert<T> inWindow(BoundedWindow window)

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window.

The assertion will concatenate all panes present in the provided window if the Trigger produces multiple panes. If the windowing strategy accumulates fired panes and triggers fire multple times, consider using instead PAssert.IterableAssert.inFinalPane(BoundedWindow) or PAssert.IterableAssert.inOnTimePane(BoundedWindow).

Specified by:

inWindow in interface PAssert.IterableAssert<T>

Returns:

a new PAssert.IterableAssert like this one but with the assertion only applied to the specified window.

inOnlyPane

public PAssert.PCollectionContentsAssert<T> inOnlyPane(BoundedWindow window)

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window.

The assertion will expect outputs to be produced to the provided window exactly once. If the upstream Trigger may produce output multiple times, consider instead using PAssert.IterableAssert.inFinalPane(BoundedWindow) or PAssert.IterableAssert.inOnTimePane(BoundedWindow).

Specified by:

inOnlyPane in interface PAssert.IterableAssert<T>

Returns:

a new PAssert.IterableAssert like this one but with the assertion only applied to the specified window.

inFinalPane

public PAssert.PCollectionContentsAssert<T> inFinalPane(BoundedWindow window)

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window, running the checker only on the final pane for each key.

If the input WindowingStrategy does not always produce final panes, the assertion may be executed over an empty input even if the trigger has fired previously. To ensure that a final pane is always produced, set the Window.ClosingBehavior of the windowing strategy (via Window.withAllowedLateness(Duration, ClosingBehavior) setting Window.ClosingBehavior to Window.ClosingBehavior.FIRE_ALWAYS).

Specified by:

inFinalPane in interface PAssert.IterableAssert<T>

Returns:

a new PAssert.IterableAssert like this one but with the assertion only applied to the specified window.

inOnTimePane

public PAssert.PCollectionContentsAssert<T> inOnTimePane(BoundedWindow window)

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window.

Specified by:

inOnTimePane in interface PAssert.IterableAssert<T>

Returns:

a new PAssert.IterableAssert like this one but with the assertion only applied to the specified window.

inEarlyPane

public PAssert.PCollectionContentsAssert<T> inEarlyPane(BoundedWindow window)

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window across all panes that were produced by the arrival of early data.

Specified by:

inEarlyPane in interface PAssert.IterableAssert<T>

Returns:

a new PAssert.IterableAssert like this one but with the assertion only applied to the specified window.

inLatePane

public PAssert.PCollectionContentsAssert<T> inLatePane(BoundedWindow window)

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert with the assertion restricted to only run on the provided window across all panes that were produced by the arrival of late data.

Specified by:

inLatePane in interface PAssert.IterableAssert<T>

Returns:

a new PAssert.IterableAssert like this one but with the assertion only applied to the specified window.

inCombinedNonLatePanes

public PAssert.PCollectionContentsAssert<T> inCombinedNonLatePanes(BoundedWindow window)

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on the provided window across all panes that were not produced by the arrival of late data.

Specified by:

inCombinedNonLatePanes in interface PAssert.IterableAssert<T>

Returns:

a new PAssert.IterableAssert like this one but with the assertion only applied to the specified window.

inEarlyGlobalWindowPanes

public PAssert.IterableAssert<T> inEarlyGlobalWindowPanes()

Description copied from interface: PAssert.IterableAssert

Creates a new PAssert.IterableAssert like this one, but with the assertion restricted to only run on panes in the GlobalWindow that were emitted before the GlobalWindow closed. These panes have PaneInfo.Timing.EARLY.

Specified by:

inEarlyGlobalWindowPanes in interface PAssert.IterableAssert<T>

containsInAnyOrder

@SafeVarargs
public final PAssert.PCollectionContentsAssert<T> containsInAnyOrder(T... expectedElements)

Checks that the Iterable contains the expected elements, in any order.

Returns this IterableAssert.

Specified by:

containsInAnyOrder in interface PAssert.IterableAssert<T>

Returns:

the same PAssert.IterableAssert builder for further assertions

containsInAnyOrder

public PAssert.PCollectionContentsAssert<T> containsInAnyOrder(Iterable<T> expectedElements)

Checks that the Iterable contains the expected elements, in any order.

Returns this IterableAssert.

Specified by:

containsInAnyOrder in interface PAssert.IterableAssert<T>

Returns:

the same PAssert.IterableAssert builder for further assertions

empty

public PAssert.PCollectionContentsAssert<T> empty()

Description copied from interface: PAssert.IterableAssert

Asserts that the iterable in question is empty.

Specified by:

empty in interface PAssert.IterableAssert<T>

Returns:

the same PAssert.IterableAssert builder for further assertions

satisfies

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

Description copied from interface: PAssert.IterableAssert

Applies the provided checking function (presumably containing assertions) to the iterable in question.

Specified by:

satisfies in interface PAssert.IterableAssert<T>

Returns:

the same PAssert.IterableAssert builder for further assertions

containsInAnyOrder

@SafeVarargs
public final PAssert.PCollectionContentsAssert<T> containsInAnyOrder(SerializableMatcher<? super T>... elementMatchers)

Checks that the Iterable contains elements that match the provided matchers, in any order.

Returns this IterableAssert.

Specified by:

containsInAnyOrder in interface PAssert.IterableAssert<T>

Returns:

the same PAssert.IterableAssert builder for further assertions

containsInAnyOrder

public PAssert.PCollectionContentsAssert<T> containsInAnyOrder()

Description copied from interface: PAssert.IterableAssert

Asserts that the iterable in question is empty.

Specified by:

containsInAnyOrder in interface PAssert.IterableAssert<T>

Returns:

the same PAssert.IterableAssert builder for further assertions

equals

@Deprecated
public boolean equals(@Nullable Object o)

Deprecated.

Object.equals(Object) is not supported on PAssert objects. If you meant to test object equality, use a variant of containsInAnyOrder(T...) instead.

Overrides:

equals in class Object

Throws:

UnsupportedOperationException - always

hashCode

@Deprecated
public int hashCode()

Deprecated.

Object.hashCode() is not supported on PAssert objects.

Overrides:

hashCode in class Object

Throws:

UnsupportedOperationException - always.