public class BulkFormatMapping extends Object
Modifier and Type | Class and Description |
---|---|
static class |
BulkFormatMapping.BulkFormatMappingBuilder
Builder to build
BulkFormatMapping . |
Constructor and Description |
---|
BulkFormatMapping(int[] indexMapping,
org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> bulkFormat) |
Modifier and Type | Method and Description |
---|---|
int[] |
getIndexMapping() |
org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> |
getReaderFactory() |
static BulkFormatMapping.BulkFormatMappingBuilder |
newBuilder(FileFormat fileFormat,
KeyValueFieldsExtractor extractor,
int[][] keyProjection,
int[][] valueProjection,
List<Predicate> filters) |
public BulkFormatMapping(int[] indexMapping, org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> bulkFormat)
@Nullable public int[] getIndexMapping()
public org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> getReaderFactory()
public static BulkFormatMapping.BulkFormatMappingBuilder newBuilder(FileFormat fileFormat, KeyValueFieldsExtractor extractor, int[][] keyProjection, int[][] valueProjection, @Nullable List<Predicate> filters)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.