Class Hierarchy
- java.lang.Object
- org.apache.flink.test.util.source.AbstractTestSourceBase<T,EnumChkptState> (implements org.apache.flink.api.connector.source.Source<T,SplitT,EnumChkT>)
- org.apache.flink.test.util.source.AbstractTestSource<T>
- org.apache.flink.test.util.source.TestReaderOutput<T> (implements org.apache.flink.api.connector.source.ReaderOutput<T>)
- org.apache.flink.test.util.source.TestSourceReader<T> (implements org.apache.flink.api.connector.source.SourceReader<T,SplitT>)
- org.apache.flink.test.util.source.TestSplit (implements org.apache.flink.api.connector.source.SourceSplit)
- org.apache.flink.test.util.source.TestSplitEnumerator<EnumChkptState> (implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT,CheckpointT>)
- org.apache.flink.test.util.source.SingleSplitEnumerator
- org.apache.flink.test.util.source.AbstractTestSourceBase<T,EnumChkptState> (implements org.apache.flink.api.connector.source.Source<T,SplitT,EnumChkT>)
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.flink.test.util.source.VoidSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)