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