public class ParquetInputFormatFactory extends Object
Constructor and Description |
---|
ParquetInputFormatFactory() |
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 producedRowType,
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> producedTypeInfo,
boolean isUtcTimestamp) |
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 producedRowType, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> producedTypeInfo, boolean isUtcTimestamp)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.