io.confluent.kafka.schemaregistry.maven.derive.schema

Class DeriveJsonSchema

java.lang.Object

io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema

io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema

public class DeriveJsonSchema
extends DeriveSchema

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOOLEAN
static String	NULL
static String	NUMBER
static String	STRING

Fields inherited from class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema

classToDataType, mapper, PRIMITIVE_SCHEMA_TYPE

Constructor Summary

Constructors

Constructor and Description
DeriveJsonSchema()

Method Summary

Modifier and Type	Method and Description
protected com.fasterxml.jackson.databind.JsonNode	convertToFormat(com.fasterxml.jackson.databind.JsonNode schema, String name) Generate json schema and check for any errors
protected com.fasterxml.jackson.databind.node.ObjectNode	mergeMultipleDataTypes(com.fasterxml.jackson.databind.node.ObjectNode mergedArray, List<com.fasterxml.jackson.databind.JsonNode> primitives, List<com.fasterxml.jackson.databind.JsonNode> records, List<com.fasterxml.jackson.databind.JsonNode> arrays, boolean check2dArray) Merge different records into one record and different arrays into one array Multiple data types are combined through oneOf
com.fasterxml.jackson.databind.node.ArrayNode	mergeMultipleMessages(List<com.fasterxml.jackson.databind.JsonNode> uniqueSchemas, Map<com.fasterxml.jackson.databind.JsonNode,com.fasterxml.jackson.databind.node.ArrayNode> schemaToIndex) Merge the unique schemas into one record by combining fields and merging data types

Methods inherited from class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema

checkName, getNullSchema, getPrimitiveSchema, getSchemaForArray, getSchemaForMultipleMessages, getSchemaForRecord, getSchemaOfAllElements, getSingleDataType, mergeArrays, mergeRecords, updateSchemaInformation

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NUMBER

public static final String NUMBER

See Also:

Constant Field Values

STRING

public static final String STRING

See Also:

Constant Field Values

BOOLEAN

public static final String BOOLEAN

See Also:

Constant Field Values

NULL

public static final String NULL

See Also:

Constant Field Values

Constructor Detail

DeriveJsonSchema

public DeriveJsonSchema()

Method Detail

mergeMultipleDataTypes

protected com.fasterxml.jackson.databind.node.ObjectNode mergeMultipleDataTypes(com.fasterxml.jackson.databind.node.ObjectNode mergedArray,
                                                                                List<com.fasterxml.jackson.databind.JsonNode> primitives,
                                                                                List<com.fasterxml.jackson.databind.JsonNode> records,
                                                                                List<com.fasterxml.jackson.databind.JsonNode> arrays,
                                                                                boolean check2dArray)

Merge different records into one record and different arrays into one array Multiple data types are combined through oneOf

Specified by:

mergeMultipleDataTypes in class DeriveSchema

mergeMultipleMessages

public com.fasterxml.jackson.databind.node.ArrayNode mergeMultipleMessages(List<com.fasterxml.jackson.databind.JsonNode> uniqueSchemas,
                                                                           Map<com.fasterxml.jackson.databind.JsonNode,com.fasterxml.jackson.databind.node.ArrayNode> schemaToIndex)

Merge the unique schemas into one record by combining fields and merging data types

Specified by:

mergeMultipleMessages in class DeriveSchema

convertToFormat

protected com.fasterxml.jackson.databind.JsonNode convertToFormat(com.fasterxml.jackson.databind.JsonNode schema,
                                                                  String name)

Generate json schema and check for any errors

Specified by:

convertToFormat in class DeriveSchema