org.apache.paimon.table.system

Class BinlogTable

java.lang.Object

org.apache.paimon.table.system.AuditLogTable

org.apache.paimon.table.system.BinlogTable

All Implemented Interfaces:

Serializable, DataTable, InnerTable, ReadonlyTable, Table

public class BinlogTable
extends AuditLogTable

A Table for reading binlog of table. The binlog format is as below.

INSERT: [+I, [co1], [col2]]

UPDATE: [+U, [co1_ub, col1_ua], [col2_ub, col2_ua]]

DELETE: [-D, [co1], [col2]]

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	BINLOG

Fields inherited from class org.apache.paimon.table.system.AuditLogTable

AUDIT_LOG, PREDICATE_CONVERTER

Constructor Summary

Constructors

Constructor and Description
BinlogTable(FileStoreTable wrapped)

Method Summary

Modifier and Type	Method and Description
Table	copy(Map<String,String> dynamicOptions) Copy this table with adding dynamic options.
String	name() A name to identify this table.
InnerTableRead	newRead()
RowType	rowType() Returns the row type of this table.

Methods inherited from class org.apache.paimon.table.system.AuditLogTable

branchManager, coreOptions, fileIO, indexManifestFileReader, latestSnapshotId, location, manifestFileReader, manifestListReader, newScan, newSnapshotReader, newStreamScan, options, partitionKeys, primaryKeys, schemaManager, snapshot, snapshotManager, switchToBranch, 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, 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

Field Detail

BINLOG

public static final String BINLOG

See Also:

Constant Field Values

Constructor Detail

BinlogTable

public BinlogTable(FileStoreTable wrapped)

Method Detail

name

public String name()

Description copied from interface: Table

A name to identify this table.

Specified by:

name in interface Table

Overrides:

name in class AuditLogTable

rowType

public RowType rowType()

Description copied from interface: Table

Returns the row type of this table.

Specified by:

rowType in interface Table

Overrides:

rowType in class AuditLogTable

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

Overrides:

newRead in class AuditLogTable

copy

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

Description copied from interface: Table

Copy this table with adding dynamic options.

Specified by:

copy in interface Table

Overrides:

copy in class AuditLogTable