org.apache.paimon.table.system

Class ReadOptimizedTable

java.lang.Object

org.apache.paimon.table.system.ReadOptimizedTable

All Implemented Interfaces:

Serializable, DataTable, InnerTable, ReadonlyTable, Table

public class ReadOptimizedTable
extends Object
implements DataTable, ReadonlyTable

A Table optimized for reading by avoiding merging files.

• For primary key tables, this system table only scans files on top level.
• For append only tables, as all files can be read without merging, this system table does nothing special.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	READ_OPTIMIZED

Constructor Summary

Constructors

Constructor and Description
ReadOptimizedTable(FileStoreTable wrapped)

Method Summary

Modifier and Type	Method and Description
BranchManager	branchManager()
Table	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
CoreOptions	coreOptions()
FileIO	fileIO()
SimpleFileReader<IndexManifestEntry>	indexManifestFileReader() Reader to read index manifest entry from index manifest file.
OptionalLong	latestSnapshotId() Get the latest snapshot id for this table, or empty if there are no snapshots.
Path	location()
SimpleFileReader<ManifestEntry>	manifestFileReader() Reader to read manifest entry from manifest file.
SimpleFileReader<ManifestFileMeta>	manifestListReader() Reader to read manifest file meta from manifest list file.
String	name() A name to identify this table.
InnerTableRead	newRead()
DataTableBatchScan	newScan()
SnapshotReader	newSnapshotReader()
StreamDataTableScan	newStreamScan()
Map<String,String>	options() Options of this table.
List<String>	partitionKeys() Partition keys of this table.
List<String>	primaryKeys() Primary keys of this table.
RowType	rowType() Returns the row type of this table.
Snapshot	snapshot(long snapshotId) Get the Snapshot from snapshot id.
SnapshotManager	snapshotManager()
DataTable	switchToBranch(String branchName) Get DataTable with branch identified by branchName.
TagManager	tagManager()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.table.ReadonlyTable

comment, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, fastForward, newBatchWriteBuilder, newCommit, newExpireChangelog, newExpireSnapshots, newStreamWriteBuilder, newWrite, newWriteSelector, rollbackTo, rollbackTo, statistics

Methods inherited from interface org.apache.paimon.table.InnerTable

newReadBuilder

Methods inherited from interface org.apache.paimon.table.Table

deleteBranches, deleteTags, fullName

Field Detail

READ_OPTIMIZED

public static final String READ_OPTIMIZED

See Also:

Constant Field Values

Constructor Detail

ReadOptimizedTable

public ReadOptimizedTable(FileStoreTable wrapped)

Method Detail

latestSnapshotId

public OptionalLong latestSnapshotId()

Description copied from interface: Table

Get the latest snapshot id for this table, or empty if there are no snapshots.

Specified by:

latestSnapshotId in interface ReadonlyTable

Specified by:

latestSnapshotId in interface Table

snapshot

public Snapshot snapshot(long snapshotId)

Description copied from interface: Table

Get the Snapshot from snapshot id.

Specified by:

snapshot in interface ReadonlyTable

Specified by:

snapshot in interface Table

manifestListReader

public SimpleFileReader<ManifestFileMeta> manifestListReader()

Description copied from interface: Table

Reader to read manifest file meta from manifest list file.

Specified by:

manifestListReader in interface ReadonlyTable

Specified by:

manifestListReader in interface Table

manifestFileReader

public SimpleFileReader<ManifestEntry> manifestFileReader()

Description copied from interface: Table

Reader to read manifest entry from manifest file.

Specified by:

manifestFileReader in interface ReadonlyTable

Specified by:

manifestFileReader in interface Table

indexManifestFileReader

public SimpleFileReader<IndexManifestEntry> indexManifestFileReader()

Description copied from interface: Table

Reader to read index manifest entry from index manifest file.

Specified by:

indexManifestFileReader in interface ReadonlyTable

Specified by:

indexManifestFileReader in interface Table

name

public String name()

Description copied from interface: Table

A name to identify this table.

Specified by:

name in interface Table

rowType

public RowType rowType()

Description copied from interface: Table

Returns the row type of this table.

Specified by:

rowType in interface Table

partitionKeys

public List<String> partitionKeys()

Description copied from interface: Table

Partition keys of this table.

Specified by:

partitionKeys in interface ReadonlyTable

Specified by:

partitionKeys in interface Table

options

public Map<String,String> options()

Description copied from interface: Table

Options of this table.

Specified by:

options in interface ReadonlyTable

Specified by:

options in interface Table

primaryKeys

public List<String> primaryKeys()

Description copied from interface: Table

Primary keys of this table.

Specified by:

primaryKeys in interface Table

newSnapshotReader

public SnapshotReader newSnapshotReader()

Specified by:

newSnapshotReader in interface DataTable

newScan

public DataTableBatchScan newScan()

Specified by:

newScan in interface DataTable

Specified by:

newScan in interface InnerTable

newStreamScan

public StreamDataTableScan newStreamScan()

Specified by:

newStreamScan in interface InnerTable

Specified by:

newStreamScan in interface ReadonlyTable

coreOptions

public CoreOptions coreOptions()

Specified by:

coreOptions in interface DataTable

location

public Path location()

Specified by:

location in interface DataTable

snapshotManager

public SnapshotManager snapshotManager()

Specified by:

snapshotManager in interface DataTable

tagManager

public TagManager tagManager()

Specified by:

tagManager in interface DataTable

branchManager

public BranchManager branchManager()

Specified by:

branchManager in interface DataTable

switchToBranch

public DataTable switchToBranch(String branchName)

Description copied from interface: DataTable

Get DataTable with branch identified by branchName. Note that this method does not keep dynamic options in current table.

Specified by:

switchToBranch in interface DataTable

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

copy

public Table copy(Map<String,String> dynamicOptions)

Description copied from interface: Table

Copy this table with adding dynamic options.

Specified by:

copy in interface Table

fileIO

public FileIO fileIO()

Specified by:

fileIO in interface DataTable