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

Class DeriveSchemaUtils

java.lang.Object

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

public class DeriveSchemaUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
DeriveSchemaUtils()

Method Summary

Modifier and Type	Method and Description
static List<com.fasterxml.jackson.databind.JsonNode>	getListFromArray(com.fasterxml.jackson.databind.JsonNode field)
static List<String>	getSortedKeys(com.fasterxml.jackson.databind.JsonNode message)
static List<com.fasterxml.jackson.databind.JsonNode>	getUnique(List<com.fasterxml.jackson.databind.JsonNode> schemas)
static void	groupItems(com.fasterxml.jackson.databind.JsonNode element, List<com.fasterxml.jackson.databind.JsonNode> items, List<com.fasterxml.jackson.databind.JsonNode> records, List<com.fasterxml.jackson.databind.JsonNode> arrays)
static void	mergeNumberTypes(List<com.fasterxml.jackson.databind.JsonNode> primitives)
static void	replaceEachField(com.fasterxml.jackson.databind.JsonNode mergedArray, List<com.fasterxml.jackson.databind.JsonNode> uniqueRecords)
static com.fasterxml.jackson.databind.node.ArrayNode	sortJsonArrayList(com.fasterxml.jackson.databind.node.ArrayNode array)
static com.fasterxml.jackson.databind.node.ObjectNode	sortObjectNode(com.fasterxml.jackson.databind.node.ObjectNode node)

Methods inherited from class java.lang.Object

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

Constructor Detail

DeriveSchemaUtils

public DeriveSchemaUtils()

Method Detail

getUnique

public static List<com.fasterxml.jackson.databind.JsonNode> getUnique(List<com.fasterxml.jackson.databind.JsonNode> schemas)

getListFromArray

public static List<com.fasterxml.jackson.databind.JsonNode> getListFromArray(com.fasterxml.jackson.databind.JsonNode field)

getSortedKeys

public static List<String> getSortedKeys(com.fasterxml.jackson.databind.JsonNode message)

groupItems

public static void groupItems(com.fasterxml.jackson.databind.JsonNode element,
                              List<com.fasterxml.jackson.databind.JsonNode> items,
                              List<com.fasterxml.jackson.databind.JsonNode> records,
                              List<com.fasterxml.jackson.databind.JsonNode> arrays)

sortObjectNode

public static com.fasterxml.jackson.databind.node.ObjectNode sortObjectNode(com.fasterxml.jackson.databind.node.ObjectNode node)

mergeNumberTypes

public static void mergeNumberTypes(List<com.fasterxml.jackson.databind.JsonNode> primitives)

replaceEachField

public static void replaceEachField(com.fasterxml.jackson.databind.JsonNode mergedArray,
                                    List<com.fasterxml.jackson.databind.JsonNode> uniqueRecords)

sortJsonArrayList

public static com.fasterxml.jackson.databind.node.ArrayNode sortJsonArrayList(com.fasterxml.jackson.databind.node.ArrayNode array)