Modifier and Type | Method and Description |
---|---|
FormatReaderFactory |
FileFormat.createReaderFactory(RowType rowType) |
abstract FormatReaderFactory |
FileFormat.createReaderFactory(RowType projectedRowType,
List<Predicate> filters)
Create a
FormatReaderFactory from the type, with projection pushed down. |
Modifier and Type | Class and Description |
---|---|
class |
AvroBulkFormat
Provides a
FormatReaderFactory for Avro records. |
Modifier and Type | Method and Description |
---|---|
FormatReaderFactory |
AvroFileFormat.createReaderFactory(RowType projectedRowType,
List<Predicate> filters) |
Modifier and Type | Class and Description |
---|---|
class |
OrcReaderFactory
An ORC reader that produces a stream of
ColumnarRow records. |
Modifier and Type | Method and Description |
---|---|
FormatReaderFactory |
OrcFileFormat.createReaderFactory(RowType projectedRowType,
List<Predicate> filters) |
Modifier and Type | Class and Description |
---|---|
class |
ParquetReaderFactory
Parquet
FormatReaderFactory that reads data from the file to VectorizedColumnBatch in vectorized mode. |
Modifier and Type | Method and Description |
---|---|
FormatReaderFactory |
ParquetFileFormat.createReaderFactory(RowType projectedRowType,
List<Predicate> filters) |
Constructor and Description |
---|
IcebergManifestFile(FileIO fileIO,
RowType partitionType,
FormatReaderFactory readerFactory,
FormatWriterFactory writerFactory,
String compression,
PathFactory pathFactory,
MemorySize targetFileSize) |
IcebergManifestList(FileIO fileIO,
FormatReaderFactory readerFactory,
FormatWriterFactory writerFactory,
String compression,
PathFactory pathFactory) |
Constructor and Description |
---|
FileRecordReader(FormatReaderFactory readerFactory,
FormatReaderFactory.Context context,
int[] indexMapping,
CastFieldGetter[] castMapping,
PartitionInfo partitionInfo) |
Modifier and Type | Field and Description |
---|---|
protected FormatReaderFactory |
ObjectsFile.readerFactory |
Modifier and Type | Method and Description |
---|---|
FormatReaderFactory |
BulkFormatMapping.getReaderFactory() |
Modifier and Type | Method and Description |
---|---|
static RecordReader<InternalRow> |
FileUtils.createFormatReader(FileIO fileIO,
FormatReaderFactory format,
Path file,
Long fileSize) |
Constructor and Description |
---|
BulkFormatMapping(int[] indexMapping,
CastFieldGetter[] castMapping,
Pair<int[],RowType> partitionPair,
FormatReaderFactory bulkFormat) |
ObjectsFile(FileIO fileIO,
ObjectSerializer<T> serializer,
RowType formatType,
FormatReaderFactory readerFactory,
FormatWriterFactory writerFactory,
String compression,
PathFactory pathFactory,
SegmentsCache<Path> cache) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.