public class ParquetFileSystemFormatFactory extends Object implements FileSystemFormatFactory
FileSystemFormatFactory
for file system.Modifier and Type | Class and Description |
---|---|
static class |
ParquetFileSystemFormatFactory.ParquetInputFormat
An implementation of
ParquetInputFormat to read RowData records from Parquet
files. |
FileSystemFormatFactory.ReaderContext, FileSystemFormatFactory.WriterContext
Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
static ConfigOption<Boolean> |
UTC_TIMEZONE |
Constructor and Description |
---|
ParquetFileSystemFormatFactory() |
Modifier and Type | Method and Description |
---|---|
Optional<BulkWriter.Factory<RowData>> |
createBulkWriterFactory(FileSystemFormatFactory.WriterContext context)
Create
BulkWriter.Factory writer. |
Optional<Encoder<RowData>> |
createEncoder(FileSystemFormatFactory.WriterContext context)
Create
Encoder writer. |
InputFormat<RowData,?> |
createReader(FileSystemFormatFactory.ReaderContext context)
Create
InputFormat reader. |
String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
Set<ConfigOption<?>> |
optionalOptions()
Returns a set of
ConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions() . |
Set<ConfigOption<?>> |
requiredOptions()
Returns a set of
ConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions() . |
public static final String IDENTIFIER
public static final ConfigOption<Boolean> UTC_TIMEZONE
public String factoryIdentifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. kafka-0.10
).
factoryIdentifier
in interface Factory
public Set<ConfigOption<?>> requiredOptions()
Factory
ConfigOption
that an implementation of this factory requires in
addition to Factory.optionalOptions()
.
See the documentation of Factory
for more information.
requiredOptions
in interface Factory
public Set<ConfigOption<?>> optionalOptions()
Factory
ConfigOption
that an implementation of this factory consumes in
addition to Factory.requiredOptions()
.
See the documentation of Factory
for more information.
optionalOptions
in interface Factory
public InputFormat<RowData,?> createReader(FileSystemFormatFactory.ReaderContext context)
FileSystemFormatFactory
InputFormat
reader.createReader
in interface FileSystemFormatFactory
public Optional<BulkWriter.Factory<RowData>> createBulkWriterFactory(FileSystemFormatFactory.WriterContext context)
FileSystemFormatFactory
BulkWriter.Factory
writer.createBulkWriterFactory
in interface FileSystemFormatFactory
public Optional<Encoder<RowData>> createEncoder(FileSystemFormatFactory.WriterContext context)
FileSystemFormatFactory
Encoder
writer.createEncoder
in interface FileSystemFormatFactory
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.