Package | Description |
---|---|
org.apache.flink.table.store.table | |
org.apache.flink.table.store.table.source | |
org.apache.flink.table.store.table.system |
Modifier and Type | Method and Description |
---|---|
TableScan |
Table.newScan() |
Modifier and Type | Interface and Description |
---|---|
interface |
DataTableScan
A
TableScan for reading data. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataTableScan
An abstraction layer above
FileStoreScan to provide input split generation. |
Modifier and Type | Method and Description |
---|---|
default TableScan |
TableScan.withFilter(List<Predicate> predicates) |
TableScan |
TableScan.withFilter(Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
TableScan |
SnapshotsTable.newScan() |
TableScan |
SchemasTable.newScan() |
TableScan |
OptionsTable.newScan() |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.