Package org.apache.flink.test.streaming.runtime.util
-
Class Summary Class Description TestListResultSink<T> Thread-safe sink for collecting elements into an on-heap list.TestListWrapper Catalog for lists stored byTestListResultSink.
| Class | Description |
|---|---|
| TestListResultSink<T> |
Thread-safe sink for collecting elements into an on-heap list.
|
| TestListWrapper |
Catalog for lists stored by
TestListResultSink. |