public class AppendOnlyFileStoreRead extends Object implements FileStoreRead<org.apache.flink.table.data.RowData>
Constructor and Description |
---|
AppendOnlyFileStoreRead(SchemaManager schemaManager,
long schemaId,
org.apache.flink.table.types.logical.RowType rowType,
FileFormat fileFormat,
FileStorePathFactory pathFactory) |
Modifier and Type | Method and Description |
---|---|
RecordReader<org.apache.flink.table.data.RowData> |
createReader(DataSplit split)
Create a
RecordReader from split. |
FileStoreRead<org.apache.flink.table.data.RowData> |
withFilter(Predicate predicate) |
FileStoreRead<org.apache.flink.table.data.RowData> |
withProjection(int[][] projectedFields) |
public AppendOnlyFileStoreRead(SchemaManager schemaManager, long schemaId, org.apache.flink.table.types.logical.RowType rowType, FileFormat fileFormat, FileStorePathFactory pathFactory)
public FileStoreRead<org.apache.flink.table.data.RowData> withProjection(int[][] projectedFields)
public FileStoreRead<org.apache.flink.table.data.RowData> withFilter(Predicate predicate)
withFilter
in interface FileStoreRead<org.apache.flink.table.data.RowData>
public RecordReader<org.apache.flink.table.data.RowData> createReader(DataSplit split) throws IOException
FileStoreRead
RecordReader
from split.createReader
in interface FileStoreRead<org.apache.flink.table.data.RowData>
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.