Package | Description |
---|---|
org.apache.flink.table.store.table | |
org.apache.flink.table.store.table.source |
Modifier and Type | Method and Description |
---|---|
AbstractDataTableScan |
ChangelogValueCountFileStoreTable.newScan() |
AbstractDataTableScan |
AppendOnlyFileStoreTable.newScan() |
AbstractDataTableScan |
ChangelogWithKeyFileStoreTable.newScan() |
Modifier and Type | Method and Description |
---|---|
AbstractDataTableScan |
AbstractDataTableScan.withBucket(int bucket) |
AbstractDataTableScan |
AbstractDataTableScan.withFilter(Predicate predicate) |
AbstractDataTableScan |
AbstractDataTableScan.withKind(ScanKind scanKind) |
AbstractDataTableScan |
AbstractDataTableScan.withLevel(int level) |
AbstractDataTableScan |
AbstractDataTableScan.withSnapshot(long snapshotId) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.