public class AuditLogTable extends Object implements DataTable
Table
for reading audit log of table.Modifier and Type | Field and Description |
---|---|
static String |
AUDIT_LOG |
static PredicateReplaceVisitor |
PREDICATE_CONVERTER |
static String |
ROW_KIND |
Constructor and Description |
---|
AuditLogTable(FileStoreTable dataTable) |
Modifier and Type | Method and Description |
---|---|
Table |
copy(Map<String,String> dynamicOptions) |
org.apache.flink.core.fs.Path |
location() |
String |
name() |
TableRead |
newRead() |
DataTableScan |
newScan() |
CoreOptions |
options() |
org.apache.flink.table.types.logical.RowType |
rowType() |
SnapshotManager |
snapshotManager() |
public static final String AUDIT_LOG
public static final String ROW_KIND
public static final PredicateReplaceVisitor PREDICATE_CONVERTER
public AuditLogTable(FileStoreTable dataTable)
public org.apache.flink.table.types.logical.RowType rowType()
public DataTableScan newScan()
public CoreOptions options()
public SnapshotManager snapshotManager()
snapshotManager
in interface DataTable
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.