@Internal public class JsonParserToRowDataConverters extends Object implements Serializable
JsonParser
to RowData
.Modifier and Type | Class and Description |
---|---|
static interface |
JsonParserToRowDataConverters.JsonParserToRowDataConverter
Runtime converter that converts
JsonParser s into objects of Flink Table & SQL
internal data structures. |
Constructor and Description |
---|
JsonParserToRowDataConverters(boolean failOnMissingField,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
Modifier and Type | Method and Description |
---|---|
JsonParserToRowDataConverters.JsonParserToRowDataConverter |
createConverter(String[][] projectedFields,
RowType rowType)
Creates a runtime nested converter which is null safe.
|
JsonParserToRowDataConverters.JsonParserToRowDataConverter |
createRowConverter(RowType rowType) |
static void |
skipToNextField(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jp) |
public JsonParserToRowDataConverters(boolean failOnMissingField, boolean ignoreParseErrors, TimestampFormat timestampFormat)
public JsonParserToRowDataConverters.JsonParserToRowDataConverter createConverter(String[][] projectedFields, RowType rowType)
public JsonParserToRowDataConverters.JsonParserToRowDataConverter createRowConverter(RowType rowType)
public static void skipToNextField(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jp) throws IOException
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.