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

Class SingleThreadedIteratorSource<T>

java.lang.Object
org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource<T>
Type Parameters:
T - The return type of the source
All Implemented Interfaces:
Serializable, org.apache.flink.api.connector.source.Source<T,org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,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 Object implements org.apache.flink.api.connector.source.Source<T,org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,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:

  • Constructor Summary

    Constructors
    Constructor
    Description
    SingleThreadedIteratorSource()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,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<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>,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, 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 Details

    • SingleThreadedIteratorSource

      public SingleThreadedIteratorSource()

  • Method Details

    • createEnumerator

      public org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,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>,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>,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, 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>,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>,Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>

    • getEnumeratorCheckpointSerializer

      public org.apache.flink.core.io.SimpleVersionedSerializer<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>,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 Exception
      Specified by:
      createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<T,org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>
      Throws:
      Exception