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

Class DeriveAvroSchema

java.lang.Object

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

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

public class DeriveAvroSchema
extends DeriveSchema

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOOLEAN
static String	DOUBLE
static String	INT
static String	LONG
static String	NULL
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
DeriveAvroSchema()

Method Summary

Modifier and Type	Method and Description
protected com.fasterxml.jackson.databind.JsonNode	convertToFormat(com.fasterxml.jackson.databind.JsonNode schema, String name) Convert json schema template to avro format and validate generated schema
protected com.fasterxml.jackson.databind.node.ObjectNode	convertToFormatArray(com.fasterxml.jackson.databind.JsonNode schema, String name)
protected com.fasterxml.jackson.databind.node.ObjectNode	convertToFormatForRecord(com.fasterxml.jackson.databind.JsonNode schema, String name)
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)
protected 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) Using mergeRecords to combine number and union types of fields
protected void	mergeUnions(List<com.fasterxml.jackson.databind.JsonNode> records, List<com.fasterxml.jackson.databind.JsonNode> primitives) Check for fields with type union and null value, and if possible merge them Check recursively for records if there are multiple 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

DOUBLE

public static final String DOUBLE

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

INT

public static final String INT

See Also:

Constant Field Values

LONG

public static final String LONG

See Also:

Constant Field Values

NULL

public static final String NULL

See Also:

Constant Field Values

Constructor Detail

DeriveAvroSchema

public DeriveAvroSchema()

Method Detail

mergeMultipleMessages

protected 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)

Using mergeRecords to combine number and union types of fields

Specified by:

mergeMultipleMessages in class DeriveSchema

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)

Specified by:

mergeMultipleDataTypes in class DeriveSchema

convertToFormat

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

Convert json schema template to avro format and validate generated schema

Specified by:

convertToFormat in class DeriveSchema

convertToFormatForRecord

protected com.fasterxml.jackson.databind.node.ObjectNode convertToFormatForRecord(com.fasterxml.jackson.databind.JsonNode schema,
                                                                                  String name)

convertToFormatArray

protected com.fasterxml.jackson.databind.node.ObjectNode convertToFormatArray(com.fasterxml.jackson.databind.JsonNode schema,
                                                                              String name)

mergeUnions

protected void mergeUnions(List<com.fasterxml.jackson.databind.JsonNode> records,
                           List<com.fasterxml.jackson.databind.JsonNode> primitives)

Check for fields with type union and null value, and if possible merge them Check recursively for records if there are multiple types