Package 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	Description
static final String	CONNECT_INDEX_PROP
static final String	CONNECT_PARAMETERS_PROP
static final String	CONNECT_TYPE_BYTES
static final String	CONNECT_TYPE_FLOAT32
static final String	CONNECT_TYPE_FLOAT64
static final String	CONNECT_TYPE_INT16
static final String	CONNECT_TYPE_INT32
static final String	CONNECT_TYPE_INT64
static final String	CONNECT_TYPE_INT8
static final String	CONNECT_TYPE_MAP
static final String	CONNECT_TYPE_PROP
static final String	CONNECT_VERSION_PROP
static final String	DEFAULT_ID_PREFIX
static final String	GENERALIZED_TYPE_ENUM
static final String	GENERALIZED_TYPE_UNION
static final String	GENERALIZED_TYPE_UNION_FIELD_PREFIX
static final String	GENERALIZED_TYPE_UNION_PREFIX
static final String	JSON_ID_PROP
static final String	JSON_TYPE_ENUM
static final String	JSON_TYPE_ONE_OF
static final String	KEY_FIELD
static final String	NAMESPACE
static final String	NULL_MARKER
static final String	VALUE_FIELD

Constructor Summary

Constructors

Constructor	Description
JsonSchemaData()
JsonSchemaData(JsonSchemaDataConfig jsonSchemaDataConfig)

Method Summary

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

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 Details

JsonSchemaData

public JsonSchemaData()

JsonSchemaData

public JsonSchemaData(JsonSchemaDataConfig jsonSchemaDataConfig)

Method Details

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)