org.apache.paimon.table

Interface DataTable

All Superinterfaces:

InnerTable, Serializable, Table

All Known Subinterfaces:

FileStoreTable, ObjectTable

All Known Implementing Classes:

AuditLogTable, BinlogTable, CompactBucketsTable, DelegatedFileStoreTable, FallbackReadFileStoreTable, FileMonitorTable, LookupFileStoreTable, ObjectTable.ObjectTableImpl, PrivilegedFileStoreTable, PrivilegedObjectTable, ReadOptimizedTable

public interface DataTable
extends InnerTable

A Table for data.

Method Summary

Modifier and Type	Method and Description
BranchManager	branchManager()
CoreOptions	coreOptions()
FileIO	fileIO()
Path	location()
DataTableScan	newScan()
SnapshotReader	newSnapshotReader()
SchemaManager	schemaManager()
SnapshotManager	snapshotManager()
DataTable	switchToBranch(String branchName) Get DataTable with branch identified by branchName.
TagManager	tagManager()

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

newBatchWriteBuilder, newCommit, newRead, newReadBuilder, newStreamScan, newStreamWriteBuilder, newWrite, newWriteSelector

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

comment, copy, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteBranches, deleteTag, deleteTags, fastForward, fullName, indexManifestFileReader, latestSnapshotId, manifestFileReader, manifestListReader, name, newExpireChangelog, newExpireSnapshots, options, partitionKeys, primaryKeys, renameTag, replaceTag, rollbackTo, rollbackTo, rowType, snapshot, statistics, uuid

Method Detail

newScan

DataTableScan newScan()

Specified by:

newScan in interface InnerTable

newSnapshotReader

SnapshotReader newSnapshotReader()

coreOptions

CoreOptions coreOptions()

snapshotManager

SnapshotManager snapshotManager()

schemaManager

SchemaManager schemaManager()

tagManager

TagManager tagManager()

branchManager

BranchManager branchManager()

switchToBranch

DataTable switchToBranch(String branchName)

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

location

Path location()

fileIO

FileIO fileIO()