io.confluent.connect.json

Class JsonSchemaData

java.lang.Object

io.confluent.connect.json.JsonSchemaData

public class JsonSchemaData
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECT_INDEX_PROP
static String	CONNECT_PARAMETERS_PROP
static String	CONNECT_TYPE_BYTES
static String	CONNECT_TYPE_FLOAT32
static String	CONNECT_TYPE_FLOAT64
static String	CONNECT_TYPE_INT16
static String	CONNECT_TYPE_INT32
static String	CONNECT_TYPE_INT64
static String	CONNECT_TYPE_INT8
static String	CONNECT_TYPE_MAP
static String	CONNECT_TYPE_PROP
static String	CONNECT_VERSION_PROP
static String	DEFAULT_ID_PREFIX
static String	GENERALIZED_TYPE_ENUM
static String	GENERALIZED_TYPE_UNION
static String	GENERALIZED_TYPE_UNION_FIELD_PREFIX
static String	GENERALIZED_TYPE_UNION_PREFIX
static String	JSON_ID_PROP
static String	JSON_TYPE_ENUM
static String	JSON_TYPE_ONE_OF
static String	KEY_FIELD
static String	NAMESPACE
static String	NULL_MARKER
static String	VALUE_FIELD

Constructor Summary

Constructors

Constructor and Description
JsonSchemaData()
JsonSchemaData(JsonSchemaDataConfig jsonSchemaDataConfig)

Method Summary

Modifier and Type	Method and Description
com.fasterxml.jackson.databind.JsonNode	fromConnectData(org.apache.kafka.connect.data.Schema schema, Object logicalValue) Convert this object, in the org.apache.kafka.connect.data format, into a JSON object, returning both the schema and the converted object.
JsonSchema	fromConnectSchema(org.apache.kafka.connect.data.Schema schema)
Object	toConnectData(org.apache.kafka.connect.data.Schema schema, com.fasterxml.jackson.databind.JsonNode jsonValue)
org.apache.kafka.connect.data.Schema	toConnectSchema(JsonSchema schema)
protected org.apache.kafka.connect.data.Schema	toConnectSchema(org.everit.json.schema.Schema jsonSchema)

Methods inherited from class java.lang.Object

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

Field Detail

NAMESPACE

public static final String NAMESPACE

See Also:

Constant Field Values

KEY_FIELD

public static final String KEY_FIELD

See Also:

Constant Field Values

VALUE_FIELD

public static final String VALUE_FIELD

See Also:

Constant Field Values

CONNECT_TYPE_PROP

public static final String CONNECT_TYPE_PROP

See Also:

Constant Field Values

CONNECT_VERSION_PROP

public static final String CONNECT_VERSION_PROP

See Also:

Constant Field Values

CONNECT_PARAMETERS_PROP

public static final String CONNECT_PARAMETERS_PROP

See Also:

Constant Field Values

CONNECT_INDEX_PROP

public static final String CONNECT_INDEX_PROP

See Also:

Constant Field Values

CONNECT_TYPE_INT8

public static final String CONNECT_TYPE_INT8

See Also:

Constant Field Values

CONNECT_TYPE_INT16

public static final String CONNECT_TYPE_INT16

See Also:

Constant Field Values

CONNECT_TYPE_INT32

public static final String CONNECT_TYPE_INT32

See Also:

Constant Field Values

CONNECT_TYPE_INT64

public static final String CONNECT_TYPE_INT64

See Also:

Constant Field Values

CONNECT_TYPE_FLOAT32

public static final String CONNECT_TYPE_FLOAT32

See Also:

Constant Field Values

CONNECT_TYPE_FLOAT64

public static final String CONNECT_TYPE_FLOAT64

See Also:

Constant Field Values

CONNECT_TYPE_BYTES

public static final String CONNECT_TYPE_BYTES

See Also:

Constant Field Values

CONNECT_TYPE_MAP

public static final String CONNECT_TYPE_MAP

See Also:

Constant Field Values

DEFAULT_ID_PREFIX

public static final String DEFAULT_ID_PREFIX

See Also:

Constant Field Values

JSON_ID_PROP

public static final String JSON_ID_PROP

See Also:

Constant Field Values

JSON_TYPE_ENUM

public static final String JSON_TYPE_ENUM

See Also:

Constant Field Values

JSON_TYPE_ONE_OF

public static final String JSON_TYPE_ONE_OF

See Also:

Constant Field Values

GENERALIZED_TYPE_UNION

public static final String GENERALIZED_TYPE_UNION

See Also:

Constant Field Values

GENERALIZED_TYPE_ENUM

public static final String GENERALIZED_TYPE_ENUM

See Also:

Constant Field Values

GENERALIZED_TYPE_UNION_PREFIX

public static final String GENERALIZED_TYPE_UNION_PREFIX

See Also:

Constant Field Values

GENERALIZED_TYPE_UNION_FIELD_PREFIX

public static final String GENERALIZED_TYPE_UNION_FIELD_PREFIX

See Also:

Constant Field Values

NULL_MARKER

public static final String NULL_MARKER

See Also:

Constant Field Values

Constructor Detail

JsonSchemaData

public JsonSchemaData()

JsonSchemaData

public JsonSchemaData(JsonSchemaDataConfig jsonSchemaDataConfig)

Method Detail

fromConnectData

public com.fasterxml.jackson.databind.JsonNode fromConnectData(org.apache.kafka.connect.data.Schema schema,
                                                               Object logicalValue)

Convert this object, in the org.apache.kafka.connect.data format, into a JSON object, returning both the schema and the converted object.

toConnectData

public Object toConnectData(org.apache.kafka.connect.data.Schema schema,
                            com.fasterxml.jackson.databind.JsonNode jsonValue)

fromConnectSchema

public JsonSchema fromConnectSchema(org.apache.kafka.connect.data.Schema schema)

toConnectSchema

public org.apache.kafka.connect.data.Schema toConnectSchema(JsonSchema schema)

toConnectSchema

protected org.apache.kafka.connect.data.Schema toConnectSchema(org.everit.json.schema.Schema jsonSchema)