public final class JsonRowSchemaConverter extends Object
Row
for representing
objects and tuple arrays.
Note: This converter implements just a subset of the JSON schema specification. Union types (as well as "allOf", "anyOf", "not") are not supported yet. Simple references that link to a common definition in the document are supported. "oneOf" and arrays of types are only supported for specifying nullability.
This converter has been developed for JSON Schema draft-07 but also includes keywords of older drafts to be as compatible as possible.
Modifier and Type | Method and Description |
---|---|
static <T> TypeInformation<T> |
convert(String jsonSchema)
Converts a JSON schema into Flink's type information.
|
public static <T> TypeInformation<T> convert(String jsonSchema)
The converter can resolve simple schema references to solve those cases where entities are defined at the beginning and then used throughout a document.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.