org.apache.paimon.table.system

Class CompactBucketsTable

java.lang.Object

org.apache.paimon.table.system.CompactBucketsTable

All Implemented Interfaces:

Serializable, DataTable, InnerTable, ReadonlyTable, Table

public class CompactBucketsTable
extends Object
implements DataTable, ReadonlyTable

A table to produce modified partitions and buckets (also including files in streaming mode) for each snapshot.

Only used internally by dedicated compact job sources.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompactBucketsTable(FileStoreTable wrapped, boolean isContinuous)
CompactBucketsTable(FileStoreTable wrapped, boolean isContinuous, String databaseName)

Method Summary

Modifier and Type	Method and Description
BranchManager	branchManager()
CompactBucketsTable	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
CoreOptions	coreOptions()
FileIO	fileIO()
static RowType	getRowType()
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()
DataTableScan	newScan()
SnapshotReader	newSnapshotReader()
StreamDataTableScan	newStreamScan()
Map<String,String>	options() Options 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, partitionKeys, renameTag, replaceTag, 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

Constructor Detail

CompactBucketsTable

public CompactBucketsTable(FileStoreTable wrapped,
                           boolean isContinuous)

CompactBucketsTable

public CompactBucketsTable(FileStoreTable wrapped,
                           boolean isContinuous,
                           String databaseName)

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

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

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

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 DataTableScan 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

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

copy

public CompactBucketsTable 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

getRowType

public static RowType getRowType()