Package org.apache.iceberg.flink.source

Class FlinkInputFormat

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.flink.api.common.io.InputFormat<org.apache.flink.table.data.RowData,​FlinkInputSplit>, org.apache.flink.core.io.InputSplitSource<FlinkInputSplit>
    public class FlinkInputFormat
extends org.apache.flink.api.common.io.RichInputFormat<org.apache.flink.table.data.RowData,​FlinkInputSplit>
    Flink InputFormat for Iceberg.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      void configure​(org.apache.flink.configuration.Configuration parameters)  
      FlinkInputSplit[] createInputSplits​(int minNumSplits)  
      org.apache.flink.core.io.InputSplitAssigner getInputSplitAssigner​(FlinkInputSplit[] inputSplits)  
      org.apache.flink.api.common.io.statistics.BaseStatistics getStatistics​(org.apache.flink.api.common.io.statistics.BaseStatistics cachedStatistics)  
      org.apache.flink.table.data.RowData nextRecord​(org.apache.flink.table.data.RowData reuse)  
      void open​(FlinkInputSplit split)  
      boolean reachedEnd()  

      • Methods inherited from class org.apache.flink.api.common.io.RichInputFormat

        closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • getStatistics

        public org.apache.flink.api.common.io.statistics.BaseStatistics getStatistics​(org.apache.flink.api.common.io.statistics.BaseStatistics cachedStatistics)

      • createInputSplits

        public FlinkInputSplit[] createInputSplits​(int minNumSplits)
                                    throws java.io.IOException
        Throws:
        java.io.IOException

      • getInputSplitAssigner

        public org.apache.flink.core.io.InputSplitAssigner getInputSplitAssigner​(FlinkInputSplit[] inputSplits)

      • configure

        public void configure​(org.apache.flink.configuration.Configuration parameters)

      • reachedEnd

        public boolean reachedEnd()

      • nextRecord

        public org.apache.flink.table.data.RowData nextRecord​(org.apache.flink.table.data.RowData reuse)

      • close

        public void close()
           throws java.io.IOException
        Throws:
        java.io.IOException