org.apache.flink.test.util.source Class Hierarchy (Flink : Test utils : Connector 2.2.0-cp2 API)

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

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>)