public class CsvFileSystemFormatFactory extends Object implements FileSystemFormatFactory
Modifier and Type | Class and Description |
---|---|
static class |
CsvFileSystemFormatFactory.CsvInputFormat
InputFormat that reads csv record into
RowData . |
FileSystemFormatFactory.ReaderContext, FileSystemFormatFactory.WriterContext
Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
Constructor and Description |
---|
CsvFileSystemFormatFactory() |
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 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<Encoder<RowData>> createEncoder(FileSystemFormatFactory.WriterContext context)
FileSystemFormatFactory
Encoder
writer.createEncoder
in interface FileSystemFormatFactory
public Optional<BulkWriter.Factory<RowData>> createBulkWriterFactory(FileSystemFormatFactory.WriterContext context)
FileSystemFormatFactory
BulkWriter.Factory
writer.createBulkWriterFactory
in interface FileSystemFormatFactory
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.