DataTaskReader

java.lang.Object

org.apache.iceberg.flink.source.DataTaskReader

All Implemented Interfaces:: Serializable, FileScanTaskReader<org.apache.flink.table.data.RowData>

@Internal public class DataTaskReader extends 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 Details
- DataTaskReader
  
  public DataTaskReader(Schema readSchema)
Method Details
- 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>