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
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(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–2020 The Apache Software Foundation. All rights reserved.