io.confluent.kafka.schemaregistry.json

Class JsonSchemaUtils

java.lang.Object

io.confluent.kafka.schemaregistry.json.JsonSchemaUtils

public class JsonSchemaUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
JsonSchemaUtils()

Method Summary

Modifier and Type	Method and Description
static com.fasterxml.jackson.databind.node.ObjectNode	copyEnvelopeWithoutPayload(com.fasterxml.jackson.databind.node.ObjectNode jsonValue)
static JsonSchema	copyOf(JsonSchema schema)
static com.fasterxml.jackson.databind.node.ObjectNode	envelope(com.fasterxml.jackson.databind.JsonNode schema, com.fasterxml.jackson.databind.JsonNode payload)
static com.fasterxml.jackson.databind.node.ObjectNode	envelope(com.fasterxml.jackson.databind.JsonNode schema, List<SchemaReference> references, Map<String,com.fasterxml.jackson.databind.JsonNode> resolvedReferences, com.fasterxml.jackson.databind.JsonNode payload)
static com.fasterxml.jackson.databind.node.ObjectNode	envelope(JsonSchema schema, com.fasterxml.jackson.databind.JsonNode payload)
static com.fasterxml.jackson.databind.JsonNode	findMatchingEntity(com.fasterxml.jackson.databind.JsonNode node, SchemaEntity entity)
static com.fasterxml.jackson.databind.JsonNode	findNodeFromNameBuilder(com.fasterxml.jackson.databind.JsonNode node, LinkedList<String> identifiersList)
static JsonSchema	getSchema(Object object)
static JsonSchema	getSchema(Object object, SchemaRegistryClient client)
static JsonSchema	getSchema(Object object, SpecificationVersion specVersion, boolean useOneofForNullables, boolean failUnknownProperties, com.fasterxml.jackson.databind.ObjectMapper objectMapper, SchemaRegistryClient client)
static JsonSchema	getSchema(Object object, SpecificationVersion specVersion, boolean useOneofForNullables, boolean failUnknownProperties, SchemaRegistryClient client)
static JsonSchema	getSchema(Object object, SpecificationVersion specVersion, boolean useOneofForNullables, com.fasterxml.jackson.databind.ObjectMapper objectMapper, SchemaRegistryClient client)
static JsonSchema	getSchema(Object object, SpecificationVersion specVersion, boolean useOneofForNullables, SchemaRegistryClient client)
static JsonSchema	getSchema(Object object, SpecificationVersion specVersion, List<String> scanPackages, boolean useOneofForNullables, boolean failUnknownProperties, com.fasterxml.jackson.databind.ObjectMapper objectMapper, SchemaRegistryClient client)
static Object	getValue(Object object)
static boolean	isEnvelope(Object object)
static byte[]	toJson(Object value)
static Object	toObject(com.fasterxml.jackson.databind.JsonNode value, JsonSchema schema)
static Object	toObject(com.fasterxml.jackson.databind.JsonNode value, JsonSchema schema, boolean validate)
static Object	toObject(String value, JsonSchema schema)
static Object	toObject(String value, JsonSchema schema, boolean validate)

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonSchemaUtils

public JsonSchemaUtils()

Method Detail

envelope

public static com.fasterxml.jackson.databind.node.ObjectNode envelope(JsonSchema schema,
                                                                      com.fasterxml.jackson.databind.JsonNode payload)

envelope

public static com.fasterxml.jackson.databind.node.ObjectNode envelope(com.fasterxml.jackson.databind.JsonNode schema,
                                                                      com.fasterxml.jackson.databind.JsonNode payload)

envelope

public static com.fasterxml.jackson.databind.node.ObjectNode envelope(com.fasterxml.jackson.databind.JsonNode schema,
                                                                      List<SchemaReference> references,
                                                                      Map<String,com.fasterxml.jackson.databind.JsonNode> resolvedReferences,
                                                                      com.fasterxml.jackson.databind.JsonNode payload)

isEnvelope

public static boolean isEnvelope(Object object)

copyEnvelopeWithoutPayload

public static com.fasterxml.jackson.databind.node.ObjectNode copyEnvelopeWithoutPayload(com.fasterxml.jackson.databind.node.ObjectNode jsonValue)

copyOf

public static JsonSchema copyOf(JsonSchema schema)

getSchema

public static JsonSchema getSchema(Object object)
                            throws IOException

Throws:

IOException

getSchema

public static JsonSchema getSchema(Object object,
                                   SchemaRegistryClient client)
                            throws IOException

Throws:

IOException

getSchema

public static JsonSchema getSchema(Object object,
                                   SpecificationVersion specVersion,
                                   boolean useOneofForNullables,
                                   SchemaRegistryClient client)
                            throws IOException

Throws:

IOException

getSchema

public static JsonSchema getSchema(Object object,
                                   SpecificationVersion specVersion,
                                   boolean useOneofForNullables,
                                   boolean failUnknownProperties,
                                   SchemaRegistryClient client)
                            throws IOException

Throws:

IOException

getSchema

public static JsonSchema getSchema(Object object,
                                   SpecificationVersion specVersion,
                                   boolean useOneofForNullables,
                                   com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                   SchemaRegistryClient client)
                            throws IOException

Throws:

IOException

getSchema

public static JsonSchema getSchema(Object object,
                                   SpecificationVersion specVersion,
                                   boolean useOneofForNullables,
                                   boolean failUnknownProperties,
                                   com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                   SchemaRegistryClient client)
                            throws IOException

Throws:

IOException

getSchema

public static JsonSchema getSchema(Object object,
                                   SpecificationVersion specVersion,
                                   List<String> scanPackages,
                                   boolean useOneofForNullables,
                                   boolean failUnknownProperties,
                                   com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                   SchemaRegistryClient client)
                            throws IOException

Throws:

IOException

getValue

public static Object getValue(Object object)

toObject

public static Object toObject(com.fasterxml.jackson.databind.JsonNode value,
                              JsonSchema schema)
                       throws IOException

Throws:

IOException

toObject

public static Object toObject(com.fasterxml.jackson.databind.JsonNode value,
                              JsonSchema schema,
                              boolean validate)
                       throws IOException

Throws:

IOException

toObject

public static Object toObject(String value,
                              JsonSchema schema)
                       throws IOException

Throws:

IOException

toObject

public static Object toObject(String value,
                              JsonSchema schema,
                              boolean validate)
                       throws IOException

Throws:

IOException

toJson

public static byte[] toJson(Object value)
                     throws IOException

Throws:

IOException

findMatchingEntity

public static com.fasterxml.jackson.databind.JsonNode findMatchingEntity(com.fasterxml.jackson.databind.JsonNode node,
                                                                         SchemaEntity entity)

findNodeFromNameBuilder

public static com.fasterxml.jackson.databind.JsonNode findNodeFromNameBuilder(com.fasterxml.jackson.databind.JsonNode node,
                                                                              LinkedList<String> identifiersList)