public class OrderedKeyPrefixedProtoSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message> extends OrderedKeyProtoSerde<T> implements OrderedKeyPrefixedSerde<E,T>
ENUM_FIELD_SIZE, fields, instance, log
MAGIC_BYTE_ORDERED_KEY, MAGIC_BYTE_PROTOBUF, MAGIC_BYTE_STRING
Constructor and Description |
---|
OrderedKeyPrefixedProtoSerde(E prefix,
T instance,
com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor>> fieldMap) |
OrderedKeyPrefixedProtoSerde(E prefix,
T instance,
com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor>> fieldMap,
int numFields) |
Modifier and Type | Method and Description |
---|---|
static <E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message> |
create(E prefix,
T instance,
com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<Integer>> fieldIdsMap) |
E |
extractPrefix(org.apache.kafka.common.utils.Bytes key)
Extracts the prefix from the byte array of the key
|
byte[] |
fromJson(String json) |
org.apache.kafka.common.utils.Bytes |
key(T message) |
E |
prefix()
Returns the prefix used for serializing keys
|
OrderedKeyPrefixedSerde<E,T> |
prefixKeySerde(int numFields) |
protected byte[] |
protoToBytes(T message,
com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor> fields,
int numFields) |
protected E |
readPrefix(ByteBuffer buffer) |
String |
toJson(org.apache.kafka.common.utils.Bytes key) |
T |
toProto(org.apache.kafka.common.utils.Bytes key) |
close, configure, create, deserialize, deserialize, deserializer, encodeEnum, getMaxSerializedBytes, jsonToProto, numFields, protoToJson, readMagicByte, readProto, serialize, serialize, serializer, toHexString, type, writeMagicByte, writeProto
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
numFields, toHexString
deserialize, serialize
deserializer, serializer
public OrderedKeyPrefixedProtoSerde(E prefix, T instance, com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor>> fieldMap)
public static <E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message> OrderedKeyPrefixedSerde<E,T> create(E prefix, T instance, com.google.common.collect.ImmutableMap<E,com.google.common.collect.ImmutableList<Integer>> fieldIdsMap)
public E prefix()
OrderedKeyPrefixedSerde
public E extractPrefix(org.apache.kafka.common.utils.Bytes key)
OrderedKeyPrefixedSerde
extractPrefix
in interface OrderedKeyPrefixedSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message>
protected E readPrefix(ByteBuffer buffer)
public OrderedKeyPrefixedSerde<E,T> prefixKeySerde(int numFields)
prefixKeySerde
in interface OrderedKeyPrefixedSerde<E extends Enum<E> & com.google.protobuf.ProtocolMessageEnum,T extends com.google.protobuf.Message>
prefixKeySerde
in interface OrderedKeyUberSerde<T extends com.google.protobuf.Message>
prefixKeySerde
in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>
public org.apache.kafka.common.utils.Bytes key(T message)
key
in interface OrderedKeyUberSerde<T extends com.google.protobuf.Message>
key
in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>
protected byte[] protoToBytes(T message, com.google.common.collect.ImmutableList<com.google.protobuf.Descriptors.FieldDescriptor> fields, int numFields)
protoToBytes
in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>
public T toProto(org.apache.kafka.common.utils.Bytes key)
toProto
in interface OrderedKeyUberSerde<T extends com.google.protobuf.Message>
toProto
in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>
public byte[] fromJson(String json)
fromJson
in interface SerdeWithJson<org.apache.kafka.common.utils.Bytes>
fromJson
in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>
public String toJson(org.apache.kafka.common.utils.Bytes key)
toJson
in interface SerdeWithJson<org.apache.kafka.common.utils.Bytes>
toJson
in class OrderedKeyProtoSerde<T extends com.google.protobuf.Message>