Package org.apache.flink.core.testutils

Class FlinkMatchers

java.lang.Object

org.apache.flink.core.testutils.FlinkMatchers

@Deprecated
public class FlinkMatchers
extends Object

Deprecated.

You should assertj assertions, which have built-in assertions for CompletableFuture. To check chains of Throwable causes, use FlinkAssertions.anyCauseMatches(String) or FlinkAssertions.anyCauseMatches(Class, String)

Some reusable hamcrest matchers for Flink.

Method Summary

Modifier and Type	Method	Description
static org.hamcrest.Matcher<Throwable>	containsCause(Class<? extends Throwable> failureCause)	Deprecated. Checks for a Throwable that matches by class.
static org.hamcrest.Matcher<Throwable>	containsCause(Throwable failureCause)	Deprecated. Checks for a Throwable that matches by class and message.
static org.hamcrest.Matcher<Throwable>	containsMessage(String errorMessage)	Deprecated. Checks for a Throwable that contains the expected error message.
static <T,E extends Throwable> org.apache.flink.core.testutils.FlinkMatchers.FutureFailedMatcher<T>	futureFailedWith(Class<E> exceptionType)	Deprecated. Checks whether CompletableFuture completed already exceptionally with a specific exception type.
static <T,E extends Throwable> org.apache.flink.core.testutils.FlinkMatchers.FutureWillFailMatcher<T>	futureWillCompleteExceptionally(Class<E> exceptionType, Duration timeout)	Deprecated. Checks whether CompletableFuture will completed exceptionally within a certain time.
static <T> org.apache.flink.core.testutils.FlinkMatchers.FutureWillFailMatcher<T>	futureWillCompleteExceptionally(Duration timeout)	Deprecated. Checks whether CompletableFuture will completed exceptionally within a certain time.
static <T> org.apache.flink.core.testutils.FlinkMatchers.FutureWillFailMatcher<T>	futureWillCompleteExceptionally(Function<Throwable,Boolean> exceptionCheck, Duration timeout, String checkDescription)	Deprecated. Checks whether CompletableFuture will completed exceptionally within a certain time.
static org.hamcrest.Matcher<CompletableFuture<?>>	willNotComplete(Duration timeout)	Deprecated. Checks that a CompletableFuture won't complete within the given timeout.

Methods inherited from class java.lang.Object

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

Method Detail

futureFailedWith

public static <T,E extends Throwable> org.apache.flink.core.testutils.FlinkMatchers.FutureFailedMatcher<T> futureFailedWith(Class<E> exceptionType)

Deprecated.

Checks whether CompletableFuture completed already exceptionally with a specific exception type.

futureWillCompleteExceptionally

public static <T,E extends Throwable> org.apache.flink.core.testutils.FlinkMatchers.FutureWillFailMatcher<T> futureWillCompleteExceptionally(Class<E> exceptionType,
                                                                                                                                                   Duration timeout)

Deprecated.

Checks whether CompletableFuture will completed exceptionally within a certain time.

futureWillCompleteExceptionally

public static <T> org.apache.flink.core.testutils.FlinkMatchers.FutureWillFailMatcher<T> futureWillCompleteExceptionally(Function<Throwable,Boolean> exceptionCheck,
                                                                                                                         Duration timeout,
                                                                                                                         String checkDescription)

Deprecated.

Checks whether CompletableFuture will completed exceptionally within a certain time.

futureWillCompleteExceptionally

public static <T> org.apache.flink.core.testutils.FlinkMatchers.FutureWillFailMatcher<T> futureWillCompleteExceptionally(Duration timeout)

Deprecated.

Checks whether CompletableFuture will completed exceptionally within a certain time.

containsCause

public static org.hamcrest.Matcher<Throwable> containsCause(Class<? extends Throwable> failureCause)

Deprecated.

Checks for a Throwable that matches by class.

containsCause

public static org.hamcrest.Matcher<Throwable> containsCause(Throwable failureCause)

Deprecated.

Checks for a Throwable that matches by class and message.

containsMessage

public static org.hamcrest.Matcher<Throwable> containsMessage(String errorMessage)

Deprecated.

Checks for a Throwable that contains the expected error message.

willNotComplete

public static org.hamcrest.Matcher<CompletableFuture<?>> willNotComplete(Duration timeout)

Deprecated.

Checks that a CompletableFuture won't complete within the given timeout.