A B C F G I L M O R S T W

A

apply(Statement, Description) - 类 中的方法org.apache.flink.testutils.junit.RetryRule

assumeCredentialsAvailable() - 类 中的静态方法org.apache.flink.testutils.oss.OSSTestCredentials

assumeCredentialsAvailable() - 类 中的静态方法org.apache.flink.testutils.s3.S3TestCredentials

Checks whether credentials are available in the environment variables of this JVM.

await() - 类 中的方法org.apache.flink.core.testutils.MultiShotLatch

Waits until MultiShotLatch.trigger() is called.

await() - 类 中的方法org.apache.flink.core.testutils.OneShotLatch

Waits until OneShotLatch.trigger() is called.

await(long, TimeUnit) - 类 中的方法org.apache.flink.core.testutils.OneShotLatch

Waits until OneShotLatch.trigger() is called.

awaitBlocker() - 类 中的方法org.apache.flink.core.testutils.BlockerSync

Waits until the blocking thread has entered the method BlockerSync.block() or BlockerSync.blockNonInterruptible().

B

block() - 类 中的方法org.apache.flink.core.testutils.BlockerSync

Blocks until BlockerSync.releaseBlocker() is called or this thread is interrupted.

BlockerSync - org.apache.flink.core.testutils中的类

A utility to help synchronize two threads in cases where one of them is supposed to reach a blocking state before the other may continue.

BlockerSync() - 类 的构造器org.apache.flink.core.testutils.BlockerSync

blockForeverNonInterruptibly() - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

Permanently blocks the current thread.

blockNonInterruptible() - 类 中的方法org.apache.flink.core.testutils.BlockerSync

Blocks until BlockerSync.releaseBlocker() is called.

C

CheckedThread - org.apache.flink.core.testutils中的类

A thread that additionally catches exceptions and offers a joining method that re-throws the exceptions.

CheckedThread() - 类 的构造器org.apache.flink.core.testutils.CheckedThread

Unnamed checked thread.

CheckedThread(String) - 类 的构造器org.apache.flink.core.testutils.CheckedThread

Checked thread with a name.

CommonTestUtils - org.apache.flink.core.testutils中的类

This class contains reusable utility methods for unit tests.

CommonTestUtils() - 类 的构造器org.apache.flink.core.testutils.CommonTestUtils

containsCause(Throwable, Class<? extends Throwable>) - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

Checks whether the given throwable contains the given cause as a cause.

createClassNotInClassPath(ClassLoader) - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

Creates a new class that is not part of the classpath that the current JVM uses.

createCopySerializable(T) - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

Creates a copy of an object via Java Serialization.

createObjectForClassNotInClassPath(ClassLoader) - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

Creates a new class that is not part of the classpath that the current JVM uses, and instantiates it.

createTempFile(String) - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

Creates a temporary file that contains the given string.

credentialsAvailable() - 类 中的静态方法org.apache.flink.testutils.oss.OSSTestCredentials

credentialsAvailable() - 类 中的静态方法org.apache.flink.testutils.s3.S3TestCredentials

Checks whether S3 test credentials are available in the environment variables of this JVM.

F

FilteredClassLoader - org.apache.flink.core.testutils中的类

A ClassLoader that filters out certain classes (by name) and throws a ClassNotFoundException when they should be loaded.

FilteredClassLoader(ClassLoader, String...) - 类 的构造器org.apache.flink.core.testutils.FilteredClassLoader

Creates a new filtered classloader.

G

getInternalState(Object, String) - 类 中的静态方法org.apache.flink.mock.Whitebox

getOSSAccessKey() - 类 中的静态方法org.apache.flink.testutils.oss.OSSTestCredentials

Get OSS access key.

getOSSEndpoint() - 类 中的静态方法org.apache.flink.testutils.oss.OSSTestCredentials

Get OSS endpoint used to connect.

getOSSSecretKey() - 类 中的静态方法org.apache.flink.testutils.oss.OSSTestCredentials

Get OSS secret key.

getS3AccessKey() - 类 中的静态方法org.apache.flink.testutils.s3.S3TestCredentials

Gets the S3 Access Key.

getS3SecretKey() - 类 中的静态方法org.apache.flink.testutils.s3.S3TestCredentials

Gets the S3 Secret Key.

getTestBucketUri() - 类 中的静态方法org.apache.flink.testutils.oss.OSSTestCredentials

getTestBucketUri() - 类 中的静态方法org.apache.flink.testutils.s3.S3TestCredentials

Gets the URI for the path under which all tests should put their data.

getTestBucketUriWithScheme(String) - 类 中的静态方法org.apache.flink.testutils.oss.OSSTestCredentials

getTestBucketUriWithScheme(String) - 类 中的静态方法org.apache.flink.testutils.s3.S3TestCredentials

Gets the URI for the path under which all tests should put their data.

getWaitersCount() - 类 中的方法org.apache.flink.core.testutils.OneShotLatch

go() - 类 中的方法org.apache.flink.core.testutils.CheckedThread

This method needs to be overwritten to contain the main work logic.

I

isTriggered() - 类 中的方法org.apache.flink.core.testutils.MultiShotLatch

Checks if the latch was triggered.

isTriggered() - 类 中的方法org.apache.flink.core.testutils.OneShotLatch

Checks if the latch was triggered.

L

loadClass(String, boolean) - 类 中的方法org.apache.flink.core.testutils.FilteredClassLoader

LOG - 类 中的静态变量org.apache.flink.testutils.junit.RetryRule

log - 类 中的变量org.apache.flink.util.TestLogger

M

MultiShotLatch - org.apache.flink.core.testutils中的类

Latch for synchronizing parts of code in tests.

MultiShotLatch() - 类 的构造器org.apache.flink.core.testutils.MultiShotLatch

O

OneShotLatch - org.apache.flink.core.testutils中的类

Latch for synchronizing parts of code in tests.

OneShotLatch() - 类 的构造器org.apache.flink.core.testutils.OneShotLatch

org.apache.flink.core.testutils - 程序包 org.apache.flink.core.testutils

org.apache.flink.mock - 程序包 org.apache.flink.mock

org.apache.flink.testutils.junit - 程序包 org.apache.flink.testutils.junit

org.apache.flink.testutils.oss - 程序包 org.apache.flink.testutils.oss

org.apache.flink.testutils.s3 - 程序包 org.apache.flink.testutils.s3

org.apache.flink.util - 程序包 org.apache.flink.util

OSSTestCredentials - org.apache.flink.testutils.oss中的类

Access to credentials to access OSS buckets during integration tests.

OSSTestCredentials() - 类 的构造器org.apache.flink.testutils.oss.OSSTestCredentials

R

releaseBlocker() - 类 中的方法org.apache.flink.core.testutils.BlockerSync

Lets the blocked thread continue.

reset() - 类 中的方法org.apache.flink.core.testutils.OneShotLatch

Resets the latch so that OneShotLatch.isTriggered() returns false.

RetryOnException - org.apache.flink.testutils.junit中的注释类型

Annotation to use with RetryRule.

RetryOnFailure - org.apache.flink.testutils.junit中的注释类型

Annotation to use with RetryRule.

RetryRule - org.apache.flink.testutils.junit中的类

A rule to retry failed tests for a fixed number of times.

RetryRule() - 类 的构造器org.apache.flink.testutils.junit.RetryRule

run() - 类 中的方法org.apache.flink.core.testutils.CheckedThread

This method is final - thread work should go into the CheckedThread.go() method instead.

S

S3TestCredentials - org.apache.flink.testutils.s3中的类

Access to credentials to access S3 buckets during integration tests.

S3TestCredentials() - 类 的构造器org.apache.flink.testutils.s3.S3TestCredentials

setEnv(Map<String, String>) - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

setEnv(Map<String, String>, boolean) - 类 中的静态方法org.apache.flink.core.testutils.CommonTestUtils

setInternalState(Object, String, Object) - 类 中的静态方法org.apache.flink.mock.Whitebox

sync() - 类 中的方法org.apache.flink.core.testutils.CheckedThread

Waits until the thread is completed and checks whether any error occurred during the execution.

sync(long) - 类 中的方法org.apache.flink.core.testutils.CheckedThread

Waits with timeout until the thread is completed and checks whether any error occurred during the execution.

T

TestLogger - org.apache.flink.util中的类

Adds automatic test name logging.

TestLogger() - 类 的构造器org.apache.flink.util.TestLogger

toString() - 类 中的方法org.apache.flink.core.testutils.OneShotLatch

trigger() - 类 中的方法org.apache.flink.core.testutils.MultiShotLatch

Fires the latch.

trigger() - 类 中的方法org.apache.flink.core.testutils.OneShotLatch

Fires the latch.

trySync(long) - 类 中的方法org.apache.flink.core.testutils.CheckedThread

Waits with timeout until the thread is completed and checks whether any error occurred during the execution.

W

watchman - 类 中的变量org.apache.flink.util.TestLogger

Whitebox - org.apache.flink.mock中的类

Copied from mockito.

Whitebox() - 类 的构造器org.apache.flink.mock.Whitebox

A B C F G I L M O R S T W