org.apache.paimon.table.object

Class ObjectTable.ObjectTableImpl

java.lang.Object

org.apache.paimon.table.DelegatedFileStoreTable

org.apache.paimon.table.object.ObjectTable.ObjectTableImpl

All Implemented Interfaces:

Serializable, DataTable, FileStoreTable, InnerTable, ObjectTable, Table

Enclosing interface:

ObjectTable

public static class ObjectTable.ObjectTableImpl
extends DelegatedFileStoreTable
implements ObjectTable

An implementation for ObjectTable.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.table.object.ObjectTable

ObjectTable.Builder, ObjectTable.ObjectTableImpl

Field Summary

Fields inherited from class org.apache.paimon.table.DelegatedFileStoreTable

wrapped

Fields inherited from interface org.apache.paimon.table.object.ObjectTable

SCHEMA

Constructor Summary

Constructors

Constructor and Description
ObjectTableImpl(FileStoreTable underlyingTable, FileIO objectFileIO, String objectLocation)

Method Summary

Modifier and Type	Method and Description
ObjectTable	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
ObjectTable	copy(TableSchema newTableSchema)
ObjectTable	copyWithLatestSchema() TODO: this method is weird, old options will overwrite new options.
ObjectTable	copyWithoutTimeTravel(Map<String,String> dynamicOptions) Doesn't change table schema even when there exists time travel scan options.
BatchWriteBuilder	newBatchWriteBuilder() Returns a new batch write builder.
TableCommitImpl	newCommit(String commitUser)
StreamWriteBuilder	newStreamWriteBuilder() Returns a new stream write builder.
TableWriteImpl<?>	newWrite(String commitUser)
TableWriteImpl<?>	newWrite(String commitUser, ManifestCacheFilter manifestFilter, Integer writeId)
FileIO	objectFileIO() File io for object file system.
String	objectLocation() Object location in file system.
long	refresh()
ObjectTable	switchToBranch(String branchName) Get DataTable with branch identified by branchName.
FileStoreTable	underlyingTable() Underlying table to store metadata.

Methods inherited from class org.apache.paimon.table.DelegatedFileStoreTable

branchManager, catalogEnvironment, changelogManager, consumerManager, coreOptions, createBranch, createBranch, createRowKeyExtractor, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, equals, fastForward, fileIO, fullName, indexManifestFileReader, latestSnapshot, location, manifestFileReader, manifestListReader, name, newExpireChangelog, newExpireSnapshots, newLocalTableQuery, newRead, newScan, newSnapshotReader, newStreamScan, newWriteSelector, renameTag, replaceTag, rollbackTo, rollbackTo, schema, schemaManager, setManifestCache, setSnapshotCache, setStatsCache, snapshot, snapshotManager, statistics, store, supportStreamingReadOverwrite, tagManager, uuid, wrapped

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.table.object.ObjectTable

builder

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

bucketMode, bucketSpec, catalogEnvironment, comment, createRowKeyExtractor, newLocalTableQuery, options, partitionKeys, primaryKeys, purgeFiles, rowType, schema, setManifestCache, setSnapshotCache, setStatsCache, store, supportStreamingReadOverwrite

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

branchManager, changelogManager, consumerManager, coreOptions, location, newScan, newSnapshotReader, schemaManager, snapshotManager, tagManager

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

newRead, newReadBuilder, newStreamScan, newWriteSelector

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

createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteBranches, deleteTag, deleteTags, fastForward, fileIO, fullName, indexManifestFileReader, latestSnapshot, manifestFileReader, manifestListReader, name, newExpireChangelog, newExpireSnapshots, renameTag, replaceTag, rollbackTo, rollbackTo, snapshot, statistics, uuid

Constructor Detail

ObjectTableImpl

public ObjectTableImpl(FileStoreTable underlyingTable,
                       FileIO objectFileIO,
                       String objectLocation)

Method Detail

newBatchWriteBuilder

public BatchWriteBuilder newBatchWriteBuilder()

Description copied from interface: Table

Returns a new batch write builder.

Specified by:

newBatchWriteBuilder in interface InnerTable

Specified by:

newBatchWriteBuilder in interface Table

newStreamWriteBuilder

public StreamWriteBuilder newStreamWriteBuilder()

Description copied from interface: Table

Returns a new stream write builder.

Specified by:

newStreamWriteBuilder in interface InnerTable

Specified by:

newStreamWriteBuilder in interface Table

newWrite

public TableWriteImpl<?> newWrite(String commitUser)

Specified by:

newWrite in interface FileStoreTable

Specified by:

newWrite in interface InnerTable

Overrides:

newWrite in class DelegatedFileStoreTable

newWrite

public TableWriteImpl<?> newWrite(String commitUser,
                                  @Nullable
                                  ManifestCacheFilter manifestFilter,
                                  @Nullable
                                  Integer writeId)

Specified by:

newWrite in interface FileStoreTable

Overrides:

newWrite in class DelegatedFileStoreTable

newCommit

public TableCommitImpl newCommit(String commitUser)

Specified by:

newCommit in interface FileStoreTable

Specified by:

newCommit in interface InnerTable

Overrides:

newCommit in class DelegatedFileStoreTable

objectLocation

public String objectLocation()

Description copied from interface: ObjectTable

Object location in file system.

Specified by:

objectLocation in interface ObjectTable

underlyingTable

public FileStoreTable underlyingTable()

Description copied from interface: ObjectTable

Underlying table to store metadata.

Specified by:

underlyingTable in interface ObjectTable

objectFileIO

public FileIO objectFileIO()

Description copied from interface: ObjectTable

File io for object file system.

Specified by:

objectFileIO in interface ObjectTable

refresh

public long refresh()

Specified by:

refresh in interface ObjectTable

copy

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

Description copied from interface: Table

Copy this table with adding dynamic options.

Specified by:

copy in interface FileStoreTable

Specified by:

copy in interface ObjectTable

Specified by:

copy in interface Table

copy

public ObjectTable copy(TableSchema newTableSchema)

Specified by:

copy in interface FileStoreTable

Specified by:

copy in interface ObjectTable

copyWithoutTimeTravel

public ObjectTable copyWithoutTimeTravel(Map<String,String> dynamicOptions)

Description copied from interface: FileStoreTable

Doesn't change table schema even when there exists time travel scan options.

Specified by:

copyWithoutTimeTravel in interface FileStoreTable

Specified by:

copyWithoutTimeTravel in interface ObjectTable

copyWithLatestSchema

public ObjectTable copyWithLatestSchema()

Description copied from interface: FileStoreTable

TODO: this method is weird, old options will overwrite new options.

Specified by:

copyWithLatestSchema in interface FileStoreTable

Specified by:

copyWithLatestSchema in interface ObjectTable

switchToBranch

public ObjectTable switchToBranch(String branchName)

Description copied from interface: FileStoreTable

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

Specified by:

switchToBranch in interface FileStoreTable

Specified by:

switchToBranch in interface ObjectTable