io.confluent.connect.protobuf

Class ProtobufData

java.lang.Object

io.confluent.connect.protobuf.ProtobufData

public class ProtobufData
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECT_PRECISION_PROP
static String	CONNECT_SCALE_PROP
static String	CONNECT_TYPE_INT16
static String	CONNECT_TYPE_INT8
static String	CONNECT_TYPE_PROP
static String	DEFAULT_SCHEMA_NAME
static String	GENERALIZED_TYPE_ENUM
static String	GENERALIZED_TYPE_UNION
static String	KEY_FIELD
static String	MAP_ENTRY_SUFFIX
static String	NAMESPACE
static String	PROTOBUF_BOOL_WRAPPER_TYPE
static String	PROTOBUF_BYTES_WRAPPER_TYPE
static String	PROTOBUF_DATE_LOCATION
static String	PROTOBUF_DATE_TYPE
static String	PROTOBUF_DECIMAL_LOCATION
static String	PROTOBUF_DECIMAL_TYPE
static String	PROTOBUF_DOUBLE_WRAPPER_TYPE
static String	PROTOBUF_FLOAT_WRAPPER_TYPE
static String	PROTOBUF_INT32_WRAPPER_TYPE
static String	PROTOBUF_INT64_WRAPPER_TYPE
static String	PROTOBUF_PRECISION_PROP
static String	PROTOBUF_SCALE_PROP
static String	PROTOBUF_STRING_WRAPPER_TYPE
static String	PROTOBUF_TIME_LOCATION
static String	PROTOBUF_TIME_TYPE
static String	PROTOBUF_TIMESTAMP_LOCATION
static String	PROTOBUF_TIMESTAMP_TYPE
static String	PROTOBUF_TYPE_ENUM
static String	PROTOBUF_TYPE_ENUM_PREFIX
static String	PROTOBUF_TYPE_PROP
static String	PROTOBUF_TYPE_TAG
static String	PROTOBUF_TYPE_UNION
static String	PROTOBUF_TYPE_UNION_PREFIX
static String	PROTOBUF_UINT32_WRAPPER_TYPE
static String	PROTOBUF_UINT64_WRAPPER_TYPE
static String	PROTOBUF_WRAPPER_LOCATION
static String	VALUE_FIELD

Constructor Summary

Constructors

Constructor and Description
ProtobufData()
ProtobufData(int cacheSize)
ProtobufData(ProtobufDataConfig protobufDataConfig)

Method Summary

Modifier and Type	Method and Description
protected static String	doScrubName(String name)
protected ProtobufSchemaAndValue	fromConnectData(org.apache.kafka.connect.data.SchemaAndValue schemaAndValue)
ProtobufSchemaAndValue	fromConnectData(org.apache.kafka.connect.data.Schema schema, Object value) Convert this object, in Connect data format, into an Protobuf object.
ProtobufSchema	fromConnectSchema(org.apache.kafka.connect.data.Schema schema)
org.apache.kafka.connect.data.SchemaAndValue	toConnectData(ProtobufSchema protobufSchema, com.google.protobuf.Message message)
protected Object	toConnectData(org.apache.kafka.connect.data.Schema schema, Object value)
org.apache.kafka.connect.data.Schema	toConnectSchema(ProtobufSchema schema)

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

DEFAULT_SCHEMA_NAME

public static final String DEFAULT_SCHEMA_NAME

See Also:

Constant Field Values

MAP_ENTRY_SUFFIX

public static final String MAP_ENTRY_SUFFIX

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

PROTOBUF_TYPE_ENUM

public static final String PROTOBUF_TYPE_ENUM

See Also:

Constant Field Values

PROTOBUF_TYPE_ENUM_PREFIX

public static final String PROTOBUF_TYPE_ENUM_PREFIX

See Also:

Constant Field Values

PROTOBUF_TYPE_UNION

public static final String PROTOBUF_TYPE_UNION

See Also:

Constant Field Values

PROTOBUF_TYPE_UNION_PREFIX

public static final String PROTOBUF_TYPE_UNION_PREFIX

See Also:

Constant Field Values

PROTOBUF_TYPE_TAG

public static final String PROTOBUF_TYPE_TAG

See Also:

Constant Field Values

PROTOBUF_TYPE_PROP

public static final String PROTOBUF_TYPE_PROP

See Also:

Constant Field Values

PROTOBUF_PRECISION_PROP

public static final String PROTOBUF_PRECISION_PROP

See Also:

Constant Field Values

PROTOBUF_SCALE_PROP

public static final String PROTOBUF_SCALE_PROP

See Also:

Constant Field Values

PROTOBUF_DECIMAL_LOCATION

public static final String PROTOBUF_DECIMAL_LOCATION

See Also:

Constant Field Values

PROTOBUF_DECIMAL_TYPE

public static final String PROTOBUF_DECIMAL_TYPE

See Also:

Constant Field Values

PROTOBUF_DATE_LOCATION

public static final String PROTOBUF_DATE_LOCATION

See Also:

Constant Field Values

PROTOBUF_DATE_TYPE

public static final String PROTOBUF_DATE_TYPE

See Also:

Constant Field Values

PROTOBUF_TIME_LOCATION

public static final String PROTOBUF_TIME_LOCATION

See Also:

Constant Field Values

PROTOBUF_TIME_TYPE

public static final String PROTOBUF_TIME_TYPE

See Also:

Constant Field Values

PROTOBUF_TIMESTAMP_LOCATION

public static final String PROTOBUF_TIMESTAMP_LOCATION

See Also:

Constant Field Values

PROTOBUF_TIMESTAMP_TYPE

public static final String PROTOBUF_TIMESTAMP_TYPE

See Also:

Constant Field Values

PROTOBUF_WRAPPER_LOCATION

public static final String PROTOBUF_WRAPPER_LOCATION

See Also:

Constant Field Values

PROTOBUF_DOUBLE_WRAPPER_TYPE

public static final String PROTOBUF_DOUBLE_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_FLOAT_WRAPPER_TYPE

public static final String PROTOBUF_FLOAT_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_INT64_WRAPPER_TYPE

public static final String PROTOBUF_INT64_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_UINT64_WRAPPER_TYPE

public static final String PROTOBUF_UINT64_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_INT32_WRAPPER_TYPE

public static final String PROTOBUF_INT32_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_UINT32_WRAPPER_TYPE

public static final String PROTOBUF_UINT32_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_BOOL_WRAPPER_TYPE

public static final String PROTOBUF_BOOL_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_STRING_WRAPPER_TYPE

public static final String PROTOBUF_STRING_WRAPPER_TYPE

See Also:

Constant Field Values

PROTOBUF_BYTES_WRAPPER_TYPE

public static final String PROTOBUF_BYTES_WRAPPER_TYPE

See Also:

Constant Field Values

CONNECT_PRECISION_PROP

public static final String CONNECT_PRECISION_PROP

See Also:

Constant Field Values

CONNECT_SCALE_PROP

public static final String CONNECT_SCALE_PROP

See Also:

Constant Field Values

CONNECT_TYPE_PROP

public static final String CONNECT_TYPE_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

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

Constructor Detail

ProtobufData

public ProtobufData()

ProtobufData

public ProtobufData(int cacheSize)

ProtobufData

public ProtobufData(ProtobufDataConfig protobufDataConfig)

Method Detail

fromConnectData

public ProtobufSchemaAndValue fromConnectData(org.apache.kafka.connect.data.Schema schema,
                                              Object value)

Convert this object, in Connect data format, into an Protobuf object.

fromConnectData

protected ProtobufSchemaAndValue fromConnectData(org.apache.kafka.connect.data.SchemaAndValue schemaAndValue)

fromConnectSchema

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

toConnectData

public org.apache.kafka.connect.data.SchemaAndValue toConnectData(ProtobufSchema protobufSchema,
                                                                  com.google.protobuf.Message message)

toConnectData

protected Object toConnectData(org.apache.kafka.connect.data.Schema schema,
                               Object value)

toConnectSchema

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

doScrubName

protected static String doScrubName(String name)