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:

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

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 Details

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 IOException

Throws:

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 IOException

Throws:

IOException