Package 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	Description
static final String	BOOLEAN
static final String	DOUBLE
static final String	INT
static final String	LONG
static final String	NULL
static final String	STRING

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

classToDataType, mapper, PRIMITIVE_SCHEMA_TYPE

Constructor Summary

Constructors

Constructor	Description
DeriveAvroSchema()

Method Summary

Modifier and Type	Method	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 Details

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 Details

DeriveAvroSchema

public DeriveAvroSchema()

Method Details

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