public class FlinkInputFormat extends org.apache.flink.api.common.io.RichInputFormat<org.apache.flink.table.data.RowData,FlinkInputSplit>
InputFormat
for Iceberg.Modifier and Type | Method and 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() |
public org.apache.flink.api.common.io.statistics.BaseStatistics getStatistics(org.apache.flink.api.common.io.statistics.BaseStatistics cachedStatistics)
public FlinkInputSplit[] createInputSplits(int minNumSplits) throws java.io.IOException
java.io.IOException
public org.apache.flink.core.io.InputSplitAssigner getInputSplitAssigner(FlinkInputSplit[] inputSplits)
public void configure(org.apache.flink.configuration.Configuration parameters)
public void open(FlinkInputSplit split)
public boolean reachedEnd()
public org.apache.flink.table.data.RowData nextRecord(org.apache.flink.table.data.RowData reuse)
public void close() throws java.io.IOException
java.io.IOException