Package | Description |
---|---|
org.apache.flink.formats.csv | |
org.apache.flink.formats.parquet | |
org.apache.flink.orc |
Modifier and Type | Class and Description |
---|---|
static class |
CsvFileFormatFactory.CsvBulkDecodingFormat
CsvBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Class and Description |
---|---|
class |
ParquetColumnarRowInputFormat<SplitT extends FileSourceSplit>
A
ParquetVectorizedInputFormat to provide RowData iterator. |
static class |
ParquetFileFormatFactory.ParquetBulkDecodingFormat
ParquetBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Class and Description |
---|---|
class |
OrcColumnarRowFileInputFormat<BatchT,SplitT extends FileSourceSplit>
Deprecated.
Please use
OrcColumnarRowInputFormat . |
class |
OrcColumnarRowInputFormat<BatchT,SplitT extends FileSourceSplit>
An ORC reader that produces a stream of
ColumnarRowData records. |
static class |
OrcFileFormatFactory.OrcBulkDecodingFormat
OrcBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.