Modifier and Type | Method and Description |
---|---|
Table |
SystemCatalogTable.table() |
Constructor and Description |
---|
SystemCatalogTable(Table table) |
Modifier and Type | Field and Description |
---|---|
protected Table |
FlinkSource.table |
Constructor and Description |
---|
FlinkSource(Table table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
FlinkTableSource(Table table) |
FlinkTableSource(Table table,
Predicate predicate,
int[][] projectFields,
Long limit) |
SimpleSystemSource(Table table,
int[][] projectedFields,
Predicate predicate,
Long limit) |
SystemTableSource(Table table,
boolean isStreamingMode) |
SystemTableSource(Table table,
boolean isStreamingMode,
Predicate predicate,
int[][] projectFields,
Long limit) |
Modifier and Type | Method and Description |
---|---|
Table |
AbstractCatalog.getTable(org.apache.flink.table.catalog.ObjectPath tablePath) |
Table |
Catalog.getTable(org.apache.flink.table.catalog.ObjectPath tablePath)
Return a
Table identified by the given ObjectPath . |
Modifier and Type | Field and Description |
---|---|
protected Table |
SparkScan.table |
Constructor and Description |
---|
SparkDataSourceReader(Table table) |
SparkReaderFactory(Table table,
int[] projectedFields,
List<Predicate> predicates,
org.apache.flink.configuration.Configuration conf) |
SparkScan(Table table,
List<Predicate> predicates,
int[] projectedFields,
org.apache.flink.configuration.Configuration conf) |
SparkScanBuilder(Table table,
org.apache.flink.configuration.Configuration conf) |
SparkTable(Table table,
Lock.Factory lockFactory,
org.apache.flink.configuration.Configuration conf) |
Modifier and Type | Interface and Description |
---|---|
interface |
DataTable
A
Table for data. |
interface |
FileStoreTable
An abstraction layer above
FileStore to provide reading
and writing of RowData . |
interface |
SupportsWrite
An interface for
Table write support. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStoreTable
Abstract
FileStoreTable . |
class |
AppendOnlyFileStoreTable
FileStoreTable for WriteMode.APPEND_ONLY write mode. |
class |
ChangelogValueCountFileStoreTable
FileStoreTable for WriteMode.CHANGE_LOG write mode without primary keys. |
class |
ChangelogWithKeyFileStoreTable
FileStoreTable for WriteMode.CHANGE_LOG write mode with primary keys. |
Modifier and Type | Method and Description |
---|---|
Table |
Table.copy(Map<String,String> dynamicOptions) |
Modifier and Type | Class and Description |
---|---|
class |
AuditLogTable
A
Table for reading audit log of table. |
class |
BucketsTable
A table to produce modified partitions and buckets for each snapshot.
|
class |
OptionsTable
A
Table for showing options of table. |
class |
SchemasTable
A
Table for showing schemas of table. |
class |
SnapshotsTable
A
Table for showing committing snapshots of table. |
Modifier and Type | Method and Description |
---|---|
Table |
SnapshotsTable.copy(Map<String,String> dynamicOptions) |
Table |
BucketsTable.copy(Map<String,String> dynamicOptions) |
Table |
AuditLogTable.copy(Map<String,String> dynamicOptions) |
Table |
SchemasTable.copy(Map<String,String> dynamicOptions) |
Table |
OptionsTable.copy(Map<String,String> dynamicOptions) |
static Table |
SystemTableLoader.load(String type,
org.apache.flink.core.fs.Path location) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.