Modifier and Type | Method and Description |
---|---|
FormatWriterFactory |
CompactedChangelogReadOnlyFormat.createWriterFactory(RowType type) |
Modifier and Type | Method and Description |
---|---|
abstract FormatWriterFactory |
FileFormat.createWriterFactory(RowType type)
Create a
FormatWriterFactory from the type. |
Modifier and Type | Method and Description |
---|---|
FormatWriterFactory |
AvroFileFormat.createWriterFactory(RowType type) |
Modifier and Type | Class and Description |
---|---|
class |
OrcWriterFactory
A factory that creates an ORC
FormatWriter . |
Modifier and Type | Method and Description |
---|---|
FormatWriterFactory |
OrcFileFormat.createWriterFactory(RowType type)
The
OrcWriterFactory will create ThreadLocalClassLoaderConfiguration from the
input writer config to avoid classloader leaks. |
Modifier and Type | Class and Description |
---|---|
class |
ParquetWriterFactory
A factory that creates a Parquet
FormatWriter . |
Modifier and Type | Method and Description |
---|---|
FormatWriterFactory |
ParquetFileFormat.createWriterFactory(RowType type) |
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 |
---|
KeyValueDataFileWriter(FileIO fileIO,
FormatWriterFactory factory,
Path path,
java.util.function.Function<KeyValue,InternalRow> converter,
RowType keyType,
RowType valueType,
SimpleStatsExtractor simpleStatsExtractor,
long schemaId,
int level,
String compression,
CoreOptions options,
FileSource fileSource,
FileIndexOptions fileIndexOptions) |
RowDataFileWriter(FileIO fileIO,
FormatWriterFactory factory,
Path path,
RowType writeSchema,
SimpleStatsExtractor simpleStatsExtractor,
long schemaId,
LongCounter seqNumCounter,
String fileCompression,
SimpleColStatsCollector.Factory[] statsCollectors,
FileIndexOptions fileIndexOptions,
FileSource fileSource,
boolean asyncFileWrite,
boolean statsDenseStore) |
SingleFileWriter(FileIO fileIO,
FormatWriterFactory factory,
Path path,
java.util.function.Function<T,InternalRow> converter,
String compression,
boolean asyncWrite) |
StatsCollectingSingleFileWriter(FileIO fileIO,
FormatWriterFactory factory,
Path path,
java.util.function.Function<T,InternalRow> converter,
RowType writeSchema,
SimpleStatsExtractor simpleStatsExtractor,
String compression,
SimpleColStatsCollector.Factory[] statsCollectors,
boolean asyncWrite) |
Modifier and Type | Field and Description |
---|---|
protected FormatWriterFactory |
ObjectsFile.writerFactory |
Constructor and Description |
---|
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.