org.apache.paimon.table.system

Class FileMonitorTable

java.lang.Object

org.apache.paimon.table.system.FileMonitorTable

All Implemented Interfaces:

Serializable, DataTable, InnerTable, ReadonlyTable, Table

@Experimental
public class FileMonitorTable
extends Object
implements DataTable, ReadonlyTable

A table to produce modified files for snapshots.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileMonitorTable.FileChange Pojo to record of file change.

Constructor Summary

Constructors

Constructor and Description
FileMonitorTable(FileStoreTable wrapped)

Method Summary

Modifier and Type	Method and Description
BranchManager	branchManager()
FileMonitorTable	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.
SchemaManager	schemaManager()
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()
static FileMonitorTable.FileChange	toFileChange(InternalRow row)
static InternalRow	toRow(FileMonitorTable.FileChange change)

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, uuid

Constructor Detail

FileMonitorTable

public FileMonitorTable(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

location

public Path location()

Specified by:

location in interface DataTable

snapshotManager

public SnapshotManager snapshotManager()

Specified by:

snapshotManager in interface DataTable

schemaManager

public SchemaManager schemaManager()

Specified by:

schemaManager 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 FileMonitorTable 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()

toRow

public static InternalRow toRow(FileMonitorTable.FileChange change)
                         throws IOException

Throws:

IOException

toFileChange

public static FileMonitorTable.FileChange toFileChange(InternalRow row)
                                                throws IOException

Throws:

IOException