Package org.apache.iceberg.flink.maintenance.operator

Class SingleThreadedIteratorSource<T>

  • Type Parameters:
    T - The return type of the source
    All Implemented Interfaces:
    java.io.Serializable, org.apache.flink.api.connector.source.Source<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>, org.apache.flink.api.connector.source.SourceReaderFactory<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
    @Internal
public abstract class SingleThreadedIteratorSource<T>
extends java.lang.Object
implements org.apache.flink.api.connector.source.Source<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
    Implementation of the Source V2 API which uses an iterator to read the elements, and uses a single thread to do so.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> createEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext)  
      org.apache.flink.api.connector.source.SourceReader<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> createReader​(org.apache.flink.api.connector.source.SourceReaderContext readerContext)  
      org.apache.flink.core.io.SimpleVersionedSerializer<java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> getEnumeratorCheckpointSerializer()  
      org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> getSplitSerializer()  
      org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> restoreEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext, java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> checkpoint)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

      • Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

        getProducedType

      • Methods inherited from interface org.apache.flink.api.connector.source.Source

        getBoundedness

    • Constructor Detail

      • SingleThreadedIteratorSource

        public SingleThreadedIteratorSource()

    • Method Detail

      • createEnumerator

        public org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> createEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext)
        Specified by:
        createEnumerator in interface org.apache.flink.api.connector.source.Source<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>

      • restoreEnumerator

        public org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> restoreEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext,
                                                                                                                                                                                                                                                                                                java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> checkpoint)
        Specified by:
        restoreEnumerator in interface org.apache.flink.api.connector.source.Source<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>

      • getSplitSerializer

        public org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> getSplitSerializer()
        Specified by:
        getSplitSerializer in interface org.apache.flink.api.connector.source.Source<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>

      • getEnumeratorCheckpointSerializer

        public org.apache.flink.core.io.SimpleVersionedSerializer<java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> getEnumeratorCheckpointSerializer()
        Specified by:
        getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,​java.util.Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>

      • createReader

        public org.apache.flink.api.connector.source.SourceReader<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> createReader​(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
                                                                                                                                                                   throws java.lang.Exception
        Specified by:
        createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<T,​org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>
        Throws:
        java.lang.Exception