public final class CsvRowFormatFactory extends TableFormatFactoryBase<Row> implements SerializationSchemaFactory<Row>, DeserializationSchemaFactory<Row>
SerializationSchema
and DeserializationSchema
.Constructor and Description |
---|
CsvRowFormatFactory() |
Modifier and Type | Method and Description |
---|---|
DeserializationSchema<Row> |
createDeserializationSchema(Map<String,String> properties)
Creates and configures a
DeserializationSchema using the given properties. |
SerializationSchema<Row> |
createSerializationSchema(Map<String,String> properties)
Creates and configures a [[SerializationSchema]] using the given properties.
|
List<String> |
supportedFormatProperties()
Format specific supported properties.
|
deriveSchema, requiredContext, requiredFormatContext, supportedProperties, supportsSchemaDerivation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
supportedProperties, supportsSchemaDerivation
requiredContext
public List<String> supportedFormatProperties()
TableFormatFactoryBase
This method can be used if schema derivation is not enough.
supportedFormatProperties
in class TableFormatFactoryBase<Row>
public DeserializationSchema<Row> createDeserializationSchema(Map<String,String> properties)
DeserializationSchemaFactory
DeserializationSchema
using the given properties.createDeserializationSchema
in interface DeserializationSchemaFactory<Row>
properties
- normalized properties describing the formatpublic SerializationSchema<Row> createSerializationSchema(Map<String,String> properties)
SerializationSchemaFactory
createSerializationSchema
in interface SerializationSchemaFactory<Row>
properties
- normalized properties describing the formatCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.