Class | Description |
---|---|
BlockerSync |
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.
|
CheckedThread |
A thread that additionally catches exceptions and offers a joining method that re-throws the
exceptions.
|
CommonTestUtils |
This class contains reusable utility methods for unit tests.
|
CompletedScheduledFuture<T> |
Completed
ScheduledFuture implementation. |
FilteredClassLoader |
A ClassLoader that filters out certain classes (by name) and throws a ClassNotFoundException when
they should be loaded.
|
FlinkMatchers |
Some reusable hamcrest matchers for Flink.
|
ManuallyTriggeredScheduledExecutorService |
Simple
ScheduledExecutorService implementation for testing purposes. |
MultiShotLatch |
Latch for synchronizing parts of code in tests.
|
OneShotLatch |
Latch for synchronizing parts of code in tests.
|
ScheduledTask<T> |
ScheduledTask represents a task which is executed at a later point in time.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.