org.apache.paimon.table.source

Interface TableRead

All Known Subinterfaces:

InnerTableRead

All Known Implementing Classes:

AbstractDataTableRead, KeyValueTableRead, LookupCompactDiffRead, TableLineageTable.TableLineageRead

@Public
public interface TableRead

An abstraction layer above SplitRead to provide reading of InternalRow.

Since:

0.4.0

Method Summary

Modifier and Type	Method and Description
default RecordReader<InternalRow>	createReader(List<Split> splits)
RecordReader<InternalRow>	createReader(Split split)
default RecordReader<InternalRow>	createReader(TableScan.Plan plan)
TableRead	executeFilter()
TableRead	withIOManager(IOManager ioManager)

Method Detail

executeFilter

TableRead executeFilter()

withIOManager

TableRead withIOManager(IOManager ioManager)

createReader

RecordReader<InternalRow> createReader(Split split)
                                throws IOException

Throws:

IOException

createReader

default RecordReader<InternalRow> createReader(List<Split> splits)
                                        throws IOException

Throws:

IOException

createReader

default RecordReader<InternalRow> createReader(TableScan.Plan plan)
                                        throws IOException

Throws:

IOException