public class BinlogTable extends AuditLogTable
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]]
| Modifier and Type | Field and Description |
|---|---|
static String |
BINLOG |
AUDIT_LOG, PREDICATE_CONVERTER| Constructor and Description |
|---|
BinlogTable(FileStoreTable wrapped) |
| 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.
|
branchManager, changelogManager, consumerManager, coreOptions, fileIO, indexManifestFileReader, latestSnapshot, location, manifestFileReader, manifestListReader, newScan, newSnapshotReader, newStreamScan, options, partitionKeys, primaryKeys, schemaManager, snapshot, snapshotManager, switchToBranch, tagManagerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcomment, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, fastForward, newBatchWriteBuilder, newCommit, newExpireChangelog, newExpireSnapshots, newStreamWriteBuilder, newWrite, newWriteSelector, renameTag, replaceTag, rollbackTo, rollbackTo, statisticsnewReadBuilderdeleteBranches, deleteTags, fullName, uuidpublic static final String BINLOG
public BinlogTable(FileStoreTable wrapped)
public String name()
Tablename in interface Tablename in class AuditLogTablepublic RowType rowType()
TablerowType in interface TablerowType in class AuditLogTablepublic InnerTableRead newRead()
newRead in interface InnerTablenewRead in class AuditLogTableCopyright © 2023–2025 The Apache Software Foundation. All rights reserved.