public class OrcInputFormatFactory extends Object
Modifier and Type | Field and Description |
---|---|
static int |
BATCH_SIZE |
Constructor and Description |
---|
OrcInputFormatFactory() |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> |
create(org.apache.hadoop.conf.Configuration conf,
org.apache.flink.table.types.logical.RowType type,
int[] projection,
List<org.apache.flink.orc.OrcFilters.Predicate> orcPredicates) |
public static final int BATCH_SIZE
public static org.apache.flink.connector.file.src.reader.BulkFormat<org.apache.flink.table.data.RowData,org.apache.flink.connector.file.src.FileSourceSplit> create(org.apache.hadoop.conf.Configuration conf, org.apache.flink.table.types.logical.RowType type, int[] projection, List<org.apache.flink.orc.OrcFilters.Predicate> orcPredicates)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.