| AbstractTestSource<T> |
Abstract base class for test sources that provides default implementations for all Source V2
methods.
|
| AbstractTestSourceBase<T,EnumChkptState> |
Base class for test sources that allows customization of the enumerator checkpoint type.
|
| SingleSplitEnumerator |
A split enumerator where the first reader gets one split, others get nothing.
|
| TestReaderOutput<T> |
Test utility for capturing output from SourceReader implementations.
|
| TestSourceReader<T> |
Base class for test source readers that provides default implementations for all SourceReader
methods.
|
| TestSplit |
A simple test split implementation that can be reused across test sources.
|
| TestSplitEnumerator<EnumChkptState> |
Base split enumerator for test sources that provides sensible defaults for most methods.
|