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

A

apply(Statement, Description) - Method in class org.apache.flink.testutils.junit.RetryRule

assumeCredentialsAvailable() - Static method in class org.apache.flink.testutils.s3.S3TestCredentials

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

await() - Method in class org.apache.flink.core.testutils.MultiShotLatch

Waits until MultiShotLatch.trigger() is called.

await() - Method in class org.apache.flink.core.testutils.OneShotLatch

Waits until OneShotLatch.trigger() is called.

await(long, TimeUnit) - Method in class org.apache.flink.core.testutils.OneShotLatch

Waits until OneShotLatch.trigger() is called.

awaitBlocker() - Method in class org.apache.flink.core.testutils.BlockerSync

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

B

block() - Method in class org.apache.flink.core.testutils.BlockerSync

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

BlockerSync - Class in 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() - Constructor for class org.apache.flink.core.testutils.BlockerSync

blockForeverNonInterruptibly() - Static method in class org.apache.flink.core.testutils.CommonTestUtils

Permanently blocks the current thread.

blockNonInterruptible() - Method in class org.apache.flink.core.testutils.BlockerSync

Blocks until BlockerSync.releaseBlocker() is called.

C

CheckedThread - Class in org.apache.flink.core.testutils

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

CheckedThread() - Constructor for class org.apache.flink.core.testutils.CheckedThread

Unnamed checked thread.

CheckedThread(String) - Constructor for class org.apache.flink.core.testutils.CheckedThread

Checked thread with a name.

CommonTestUtils - Class in org.apache.flink.core.testutils

This class contains reusable utility methods for unit tests.

CommonTestUtils() - Constructor for class org.apache.flink.core.testutils.CommonTestUtils

containsCause(Throwable, Class<? extends Throwable>) - Static method in class org.apache.flink.core.testutils.CommonTestUtils

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

createClassNotInClassPath(ClassLoader) - Static method in class org.apache.flink.core.testutils.CommonTestUtils

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

createCopySerializable(T) - Static method in class org.apache.flink.core.testutils.CommonTestUtils

Creates a copy of an object via Java Serialization.

createObjectForClassNotInClassPath(ClassLoader) - Static method in class 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) - Static method in class org.apache.flink.core.testutils.CommonTestUtils

Creates a temporary file that contains the given string.

credentialsAvailable() - Static method in class org.apache.flink.testutils.s3.S3TestCredentials

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

E

execute(Runnable) - Method in class org.apache.flink.core.testutils.ManuallyTriggeredDirectExecutor

F

FilteredClassLoader - Class in 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...) - Constructor for class org.apache.flink.core.testutils.FilteredClassLoader

Creates a new filtered classloader.

G

getInternalState(Object, String) - Static method in class org.apache.flink.mock.Whitebox

getS3AccessKey() - Static method in class org.apache.flink.testutils.s3.S3TestCredentials

Gets the S3 Access Key.

getS3SecretKey() - Static method in class org.apache.flink.testutils.s3.S3TestCredentials

Gets the S3 Secret Key.

getTestBucketUri() - Static method in class org.apache.flink.testutils.s3.S3TestCredentials

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

getTestBucketUriWithScheme(String) - Static method in class org.apache.flink.testutils.s3.S3TestCredentials

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

getWaitersCount() - Method in class org.apache.flink.core.testutils.OneShotLatch

go() - Method in class org.apache.flink.core.testutils.CheckedThread

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

I

isTriggered() - Method in class org.apache.flink.core.testutils.MultiShotLatch

Checks if the latch was triggered.

isTriggered() - Method in class org.apache.flink.core.testutils.OneShotLatch

Checks if the latch was triggered.

L

loadClass(String, boolean) - Method in class org.apache.flink.core.testutils.FilteredClassLoader

LOG - Static variable in class org.apache.flink.testutils.junit.RetryRule

log - Variable in class org.apache.flink.util.TestLogger

M

ManuallyTriggeredDirectExecutor - Class in org.apache.flink.core.testutils

An executor that does not immediately execute a Runnable, but only executes it upon an explicit trigger.

ManuallyTriggeredDirectExecutor() - Constructor for class org.apache.flink.core.testutils.ManuallyTriggeredDirectExecutor

MultiShotLatch - Class in org.apache.flink.core.testutils

Latch for synchronizing parts of code in tests.

MultiShotLatch() - Constructor for class org.apache.flink.core.testutils.MultiShotLatch

N

numQueuedRunnables() - Method in class org.apache.flink.core.testutils.ManuallyTriggeredDirectExecutor

Gets the number of Runnables currently queued.

O

OneShotLatch - Class in org.apache.flink.core.testutils

Latch for synchronizing parts of code in tests.

OneShotLatch() - Constructor for class org.apache.flink.core.testutils.OneShotLatch

org.apache.flink.core.testutils - package org.apache.flink.core.testutils

org.apache.flink.mock - package org.apache.flink.mock

org.apache.flink.testutils.junit - package org.apache.flink.testutils.junit

org.apache.flink.testutils.s3 - package org.apache.flink.testutils.s3

org.apache.flink.util - package org.apache.flink.util

R

releaseBlocker() - Method in class org.apache.flink.core.testutils.BlockerSync

Lets the blocked thread continue.

reset() - Method in class org.apache.flink.core.testutils.OneShotLatch

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

RetryOnException - Annotation Type in org.apache.flink.testutils.junit

Annotation to use with RetryRule.

RetryOnFailure - Annotation Type in org.apache.flink.testutils.junit

Annotation to use with RetryRule.

RetryRule - Class in org.apache.flink.testutils.junit

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

RetryRule() - Constructor for class org.apache.flink.testutils.junit.RetryRule

run() - Method in class org.apache.flink.core.testutils.CheckedThread

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

S

S3TestCredentials - Class in org.apache.flink.testutils.s3

Access to credentials to access S3 buckets during integration tests.

S3TestCredentials() - Constructor for class org.apache.flink.testutils.s3.S3TestCredentials

setEnv(Map<String, String>) - Static method in class org.apache.flink.core.testutils.CommonTestUtils

setEnv(Map<String, String>, boolean) - Static method in class org.apache.flink.core.testutils.CommonTestUtils

setInternalState(Object, String, Object) - Static method in class org.apache.flink.mock.Whitebox

sync() - Method in class org.apache.flink.core.testutils.CheckedThread

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

sync(long) - Method in class 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 - Class in org.apache.flink.util

Adds automatic test name logging.

TestLogger() - Constructor for class org.apache.flink.util.TestLogger

toString() - Method in class org.apache.flink.core.testutils.OneShotLatch

trigger() - Method in class org.apache.flink.core.testutils.ManuallyTriggeredDirectExecutor

Triggers the next queued runnable and executes it synchronously.

trigger() - Method in class org.apache.flink.core.testutils.MultiShotLatch

Fires the latch.

trigger() - Method in class org.apache.flink.core.testutils.OneShotLatch

Fires the latch.

trySync(long) - Method in class 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 - Variable in class org.apache.flink.util.TestLogger

Whitebox - Class in org.apache.flink.mock

Copied from mockito.

Whitebox() - Constructor for class org.apache.flink.mock.Whitebox

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