org.apache.paimon.table

Interface InnerTable

All Superinterfaces:

Serializable, Table

All Known Subinterfaces:

DataTable, FileStoreTable, ReadonlyTable

All Known Implementing Classes:

AggregationFieldsTable, AllTableOptionsTable, AuditLogTable, BranchesTable, BucketsTable, CatalogOptionsTable, CompactBucketsTable, ConsumersTable, DelegatedFileStoreTable, FallbackReadFileStoreTable, FileMonitorTable, FilesTable, KnownSplitsTable, LookupFileStoreTable, ManifestsTable, OptionsTable, PartitionsTable, PrivilegedFileStoreTable, ReadOptimizedTable, SchemasTable, SinkTableLineageTable, SnapshotsTable, SourceTableLineageTable, StatisticTable, TableLineageTable, TagsTable

public interface InnerTable
extends Table

Inner table for implementation, provide newScan, newRead ... directly.

Method Summary

Modifier and Type	Method and Description
default BatchWriteBuilder	newBatchWriteBuilder() Returns a new batch write builder.
InnerTableCommit	newCommit(String commitUser)
InnerTableRead	newRead()
default ReadBuilder	newReadBuilder() Returns a new read builder.
InnerTableScan	newScan()
StreamDataTableScan	newStreamScan()
default StreamWriteBuilder	newStreamWriteBuilder() Returns a new stream write builder.
InnerTableWrite	newWrite(String commitUser)
Optional<WriteSelector>	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

Method Detail

newScan

InnerTableScan newScan()

newStreamScan

StreamDataTableScan newStreamScan()

newRead

InnerTableRead newRead()

newWriteSelector

Optional<WriteSelector> newWriteSelector()

newWrite

InnerTableWrite newWrite(String commitUser)

newCommit

InnerTableCommit newCommit(String commitUser)

newReadBuilder

default ReadBuilder newReadBuilder()

Description copied from interface: Table

Returns a new read builder.

Specified by:

newReadBuilder in interface Table

newBatchWriteBuilder

default BatchWriteBuilder newBatchWriteBuilder()

Description copied from interface: Table

Returns a new batch write builder.

Specified by:

newBatchWriteBuilder in interface Table

newStreamWriteBuilder

default StreamWriteBuilder newStreamWriteBuilder()

Description copied from interface: Table

Returns a new stream write builder.

Specified by:

newStreamWriteBuilder in interface Table