public interface TableRead
FileStoreRead
to provide reading of RowData
.Modifier and Type | Method and Description |
---|---|
default RecordReader<org.apache.flink.table.data.RowData> |
createReader(List<Split> splits) |
RecordReader<org.apache.flink.table.data.RowData> |
createReader(Split split) |
default TableRead |
withFilter(List<Predicate> predicates) |
TableRead |
withFilter(Predicate predicate) |
default TableRead |
withProjection(int[] projection) |
TableRead |
withProjection(int[][] projection) |
default TableRead withProjection(int[] projection)
TableRead withProjection(int[][] projection)
RecordReader<org.apache.flink.table.data.RowData> createReader(Split split) throws IOException
IOException
default RecordReader<org.apache.flink.table.data.RowData> createReader(List<Split> splits) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.