org.apache.flink.cdc.common.utils

类 TestCaseUtils

java.lang.Object

org.apache.flink.cdc.common.utils.TestCaseUtils

public class TestCaseUtils
extends Object

Some utility methods for creating repeated-checking test cases.

字段概要

字段

限定符和类型	字段和说明
static java.time.Duration	DEFAULT_INTERVAL
static java.time.Duration	DEFAULT_TIMEOUT

构造器概要

构造器

构造器和说明
TestCaseUtils()

方法概要

限定符和类型	方法和说明
static void	repeatedCheck(java.util.function.Supplier<Boolean> fetcher) Fetch with a (timeout, interval) duration.
static void	repeatedCheck(java.util.function.Supplier<Boolean> fetcher, java.time.Duration timeout) Fetch with a (timeout, interval) duration.
static void	repeatedCheck(java.util.function.Supplier<Boolean> fetcher, java.time.Duration timeout, java.time.Duration interval) Fetch with a (timeout, interval) duration.
static <T> void	repeatedCheck(java.util.function.Supplier<T> fetcher, java.util.function.Predicate<T> validator, java.time.Duration timeout, java.time.Duration interval) Fetch and wait with a (timeout, interval) duration.
static void	repeatedCheck(org.apache.flink.util.function.SupplierWithException<Boolean,Throwable> fetcher, java.time.Duration timeout, java.time.Duration interval, List<Class<? extends Throwable>> allowedThrowsList) Waiting for fetching values with a (timeout, interval) duration.
static <T> void	repeatedCheckAndValidate(org.apache.flink.util.function.SupplierWithException<T,Throwable> fetcher, java.util.function.Predicate<T> validator, java.time.Duration timeout, java.time.Duration interval, List<Class<? extends Throwable>> allowedThrowsList) Fetch and validate, with a (timeout, interval) duration.

从类继承的方法 java.lang.Object

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

字段详细资料

DEFAULT_TIMEOUT

public static final java.time.Duration DEFAULT_TIMEOUT

DEFAULT_INTERVAL

public static final java.time.Duration DEFAULT_INTERVAL

构造器详细资料

TestCaseUtils

public TestCaseUtils()

方法详细资料

repeatedCheck

public static void repeatedCheck(java.util.function.Supplier<Boolean> fetcher)

Fetch with a (timeout, interval) duration.

repeatedCheck

public static void repeatedCheck(java.util.function.Supplier<Boolean> fetcher,
                                 java.time.Duration timeout)

Fetch with a (timeout, interval) duration.

repeatedCheck

public static void repeatedCheck(java.util.function.Supplier<Boolean> fetcher,
                                 java.time.Duration timeout,
                                 java.time.Duration interval)

Fetch with a (timeout, interval) duration.

repeatedCheck

public static <T> void repeatedCheck(java.util.function.Supplier<T> fetcher,
                                     java.util.function.Predicate<T> validator,
                                     java.time.Duration timeout,
                                     java.time.Duration interval)

Fetch and wait with a (timeout, interval) duration.

repeatedCheck

public static void repeatedCheck(org.apache.flink.util.function.SupplierWithException<Boolean,Throwable> fetcher,
                                 java.time.Duration timeout,
                                 java.time.Duration interval,
                                 List<Class<? extends Throwable>> allowedThrowsList)

Waiting for fetching values with a (timeout, interval) duration.

repeatedCheckAndValidate

public static <T> void repeatedCheckAndValidate(org.apache.flink.util.function.SupplierWithException<T,Throwable> fetcher,
                                                java.util.function.Predicate<T> validator,
                                                java.time.Duration timeout,
                                                java.time.Duration interval,
                                                List<Class<? extends Throwable>> allowedThrowsList)

Fetch and validate, with a (timeout, interval) duration.