Package org.apache.iceberg.flink.source

Class RowDataFileScanTaskReader

java.lang.Object

org.apache.iceberg.flink.source.RowDataFileScanTaskReader

All Implemented Interfaces:

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RowDataFileScanTaskReader(Schema tableSchema, Schema projectedSchema, java.lang.String nameMapping, boolean caseSensitive, java.util.List<Expression> filters)

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

RowDataFileScanTaskReader

public RowDataFileScanTaskReader(Schema tableSchema,
                                 Schema projectedSchema,
                                 java.lang.String nameMapping,
                                 boolean caseSensitive,
                                 java.util.List<Expression> filters)

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>