org.apache.paimon.table.source

Interface TableRead

All Known Subinterfaces:

InnerTableRead

All Known Implementing Classes:

AbstractDataTableRead, KeyValueTableRead, LookupCompactDiffRead

@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)
TableRead	withMetricRegistry(MetricRegistry registry) Set MetricRegistry to table read.

Method Detail

withMetricRegistry

TableRead withMetricRegistry(MetricRegistry registry)

Set MetricRegistry to table read.

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