Package org.apache.iceberg.flink.source
Class FlinkInputFormat
- java.lang.Object
-
- org.apache.flink.api.common.io.RichInputFormat<org.apache.flink.table.data.RowData,FlinkInputSplit>
-
- org.apache.iceberg.flink.source.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>
FlinkInputFormat
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()
-
-
-
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)
-
open
public void open(FlinkInputSplit split)
-
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
-
-