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

Class DeriveProtobufSchema

java.lang.Object

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

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

public class DeriveProtobufSchema
extends DeriveSchema

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ANY_FIELD
static final String	BOOL
static final String	DOUBLE
static final String	FIELD_ENTRY
static final String	IMPORT_ANY_FIELD
static final String	INT_32
static final String	INT_64
static final String	PROTOBUF_SYNTAX
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
DeriveProtobufSchema()

Method Summary

Modifier and Type	Method	Description
protected void	checkName(String name)
protected com.fasterxml.jackson.databind.node.TextNode	convertToFormat(com.fasterxml.jackson.databind.JsonNode schema, String name)	Converts json schema template to protobuf format
protected String	convertToFormatArray(com.fasterxml.jackson.databind.JsonNode schema, String name, int fieldNum)
protected String	convertToFormatRecord(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 checkElements)	Merge different records into one record and merge number types: double and int/long If there are multiple data types or nested arrays error is returned
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)	Merge schemas for multiple messages to combine records and number types

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

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

BOOL

public static final String BOOL

See Also:

• Constant Field Values

INT_32

public static final String INT_32

See Also:

• Constant Field Values

INT_64

public static final String INT_64

See Also:

• Constant Field Values

ANY_FIELD

public static final String ANY_FIELD

See Also:

• Constant Field Values

IMPORT_ANY_FIELD

public static final String IMPORT_ANY_FIELD

See Also:

• Constant Field Values

FIELD_ENTRY

public static final String FIELD_ENTRY

See Also:

• Constant Field Values

PROTOBUF_SYNTAX

public static final String PROTOBUF_SYNTAX

See Also:

• Constant Field Values

Constructor Details

DeriveProtobufSchema

public DeriveProtobufSchema()

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)

Merge schemas for multiple messages to combine records and number types

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

Merge different records into one record and merge number types: double and int/long If there are multiple data types or nested arrays error is returned

Specified by:

mergeMultipleDataTypes in class DeriveSchema

checkName

protected void checkName(String name)

Overrides:

checkName in class DeriveSchema

convertToFormat

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

Converts json schema template to protobuf format

Specified by:

convertToFormat in class DeriveSchema

convertToFormatRecord

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

convertToFormatArray

protected String convertToFormatArray(com.fasterxml.jackson.databind.JsonNode schema,
 String name,
 int fieldNum)