Constructor and Description |
---|
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext,
TableRead tableRead,
Long limit) |
FileStoreSourceSplitReader(TableRead tableRead,
Long limit) |
Constructor and Description |
---|
TableStoreRecordReader(TableRead read,
TableStoreInputSplit split,
List<String> columnNames,
List<String> selectedColumns) |
Modifier and Type | Method and Description |
---|---|
TableRead |
ChangelogValueCountFileStoreTable.newRead() |
TableRead |
AppendOnlyFileStoreTable.newRead() |
TableRead |
ChangelogWithKeyFileStoreTable.newRead() |
TableRead |
Table.newRead() |
Modifier and Type | Class and Description |
---|---|
class |
KeyValueTableRead
An abstraction layer above
KeyValueFileStoreRead to provide reading of RowData . |
Modifier and Type | Method and Description |
---|---|
default TableRead |
TableRead.withFilter(List<Predicate> predicates) |
TableRead |
TableRead.withFilter(Predicate predicate) |
default TableRead |
TableRead.withProjection(int[] projection) |
TableRead |
TableRead.withProjection(int[][] projection) |
Modifier and Type | Method and Description |
---|---|
TableRead |
SnapshotsTable.newRead() |
TableRead |
BucketsTable.newRead() |
TableRead |
AuditLogTable.newRead() |
TableRead |
SchemasTable.newRead() |
TableRead |
OptionsTable.newRead() |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.