public static interface PAssert.IterableAssert<T>
Modifier and Type | Method and Description |
---|---|
PAssert.IterableAssert<T> |
containsInAnyOrder()
Deprecated.
Prefer
empty() to this method. |
PAssert.IterableAssert<T> |
containsInAnyOrder(java.lang.Iterable<T> expectedElements)
Asserts that the iterable in question contains the provided elements.
|
PAssert.IterableAssert<T> |
containsInAnyOrder(SerializableMatcher<? super T>... expectedElements)
Asserts that the iterable in question matches the provided elements.
|
PAssert.IterableAssert<T> |
containsInAnyOrder(T... expectedElements)
Asserts that the iterable in question contains the provided elements.
|
PAssert.IterableAssert<T> |
empty()
Asserts that the iterable in question is empty.
|
PAssert.IterableAssert<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.IterableAssert<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.IterableAssert<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.IterableAssert<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.IterableAssert<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.IterableAssert<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.IterableAssert<T> |
satisfies(SerializableFunction<java.lang.Iterable<T>,java.lang.Void> checkerFn)
Applies the provided checking function (presumably containing assertions) to the iterable in
question.
|
PAssert.IterableAssert<T> inWindow(BoundedWindow window)
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 inFinalPane(BoundedWindow)
or
inOnTimePane(BoundedWindow)
.
PAssert.IterableAssert
like this one but with the assertion only applied to the
specified window.PAssert.IterableAssert<T> inFinalPane(BoundedWindow window)
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
).
PAssert.IterableAssert
like this one but with the assertion only applied to the
specified window.PAssert.IterableAssert<T> inOnTimePane(BoundedWindow window)
PAssert.IterableAssert
like this one, but with the assertion restricted to only
run on the provided window.PAssert.IterableAssert
like this one but with the assertion only applied to the
specified window.PAssert.IterableAssert<T> inEarlyPane(BoundedWindow window)
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.IterableAssert
like this one but with the assertion only applied to the
specified window.PAssert.IterableAssert<T> inLatePane(BoundedWindow window)
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.IterableAssert
like this one but with the assertion only applied to the
specified window.PAssert.IterableAssert<T> inCombinedNonLatePanes(BoundedWindow window)
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
like this one but with the assertion only applied to the
specified window.PAssert.IterableAssert<T> inEarlyGlobalWindowPanes()
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
.PAssert.IterableAssert<T> containsInAnyOrder(T... expectedElements)
PAssert.IterableAssert
builder for further assertionsPAssert.IterableAssert<T> containsInAnyOrder(SerializableMatcher<? super T>... expectedElements)
PAssert.IterableAssert
builder for further assertions@Deprecated PAssert.IterableAssert<T> containsInAnyOrder()
empty()
to this method.PAssert.IterableAssert
builder for further assertionsPAssert.IterableAssert<T> containsInAnyOrder(java.lang.Iterable<T> expectedElements)
PAssert.IterableAssert
builder for further assertionsPAssert.IterableAssert<T> empty()
PAssert.IterableAssert
builder for further assertionsPAssert.IterableAssert<T> satisfies(SerializableFunction<java.lang.Iterable<T>,java.lang.Void> checkerFn)
PAssert.IterableAssert
builder for further assertions