Package org.apache.iceberg.flink.source

Class DataTaskReader

java.lang.Object

org.apache.iceberg.flink.source.DataTaskReader

All Implemented Interfaces:

java.io.Serializable, FileScanTaskReader<org.apache.flink.table.data.RowData>

@Internal
public class DataTaskReader
extends java.lang.Object
implements FileScanTaskReader<org.apache.flink.table.data.RowData>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DataTaskReader(Schema readSchema)

Method Summary

Modifier and Type	Method	Description
CloseableIterator<org.apache.flink.table.data.RowData>	open(FileScanTask task, InputFilesDecryptor inputFilesDecryptor)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataTaskReader

public DataTaskReader(Schema readSchema)

Method Detail

open

public CloseableIterator<org.apache.flink.table.data.RowData> open(FileScanTask task,
                                                                   InputFilesDecryptor inputFilesDecryptor)

Specified by:

open in interface FileScanTaskReader<org.apache.flink.table.data.RowData>