public final class CsvRowSchemaConverter extends Object
CsvSchema
.
In CsvSchema
, there are four types (string, number, boolean, and array). In order to
satisfy various Flink types, this class sorts out instances of TypeInformation
and LogicalType
that are not supported. It converts supported types to one of CsvSchema's types.
Note: Changes in this class need to be kept in sync with the corresponding runtime classes
CsvRowDeserializationSchema
and CsvRowSerializationSchema
.
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema |
convert(RowType rowType)
Convert
RowType to CsvSchema . |
static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema |
convert(RowTypeInfo rowType)
Convert
RowTypeInfo to CsvSchema . |
public static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema convert(RowTypeInfo rowType)
RowTypeInfo
to CsvSchema
.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.