程序包org.apache.seatunnel.translation.flink.source的分层结构

程序包分层结构:

类分层结构

  • java.lang.Object
    • org.apache.seatunnel.translation.flink.source.FlinkRowCollector (implements org.apache.seatunnel.api.source.Collector<T>)
    • org.apache.seatunnel.translation.flink.source.FlinkSource<SplitT,​EnumStateT> (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, org.apache.flink.api.connector.source.Source<T,​SplitT,​EnumChkT>)
    • org.apache.seatunnel.translation.flink.source.FlinkSourceEnumerator<SplitT,​EnumStateT> (implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT,​CheckpointT>)
    • org.apache.seatunnel.translation.flink.source.FlinkSourceReader<SplitT> (implements org.apache.flink.api.connector.source.SourceReader<T,​SplitT>)
    • org.apache.seatunnel.translation.flink.source.FlinkSourceReaderContext (implements org.apache.seatunnel.api.source.SourceReader.Context)
    • org.apache.seatunnel.translation.flink.source.FlinkSourceSplitEnumeratorContext<SplitT> (implements org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT>)
    • org.apache.seatunnel.translation.flink.source.NoMoreElementEvent (implements org.apache.flink.api.connector.source.SourceEvent)
    • org.apache.seatunnel.translation.flink.source.SourceEventWrapper (implements org.apache.flink.api.connector.source.SourceEvent)
    • org.apache.seatunnel.translation.flink.source.SplitWrapper<T> (implements org.apache.flink.api.connector.source.SourceSplit)
    • org.apache.seatunnel.translation.flink.source.SplitWrapperSerializer<SplitT> (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)