Uses of Class
org.apache.pulsar.common.schema.KeyValue
Packages that use KeyValue
Package
Description
Pulsar Client API.
Helpers which provide useful functionality for the implementation of Pulsar Client API.
This package contains data structures for schema definitions used in the Pulsar Client API.
-
Uses of KeyValue in org.apache.pulsar.client.api
Methods in org.apache.pulsar.client.api that return types with arguments of type KeyValueModifier and TypeMethodDescriptionKey Value Schema whose underneath key and value schemas are JSONSchema.Schema.KeyValue
(Class<K> key, Class<V> value, SchemaType type) Key Value Schema using passed in schema type, support JSON and AVRO currently.Key Value Schema using passed in key and value schemas.Schema.KeyValue
(Schema<K> key, Schema<V> value, KeyValueEncodingType keyValueEncodingType) Key Value Schema using passed in key, value and encoding type schemas.Schema.KV_BYTES()
Schema that can be used to encode/decode KeyValue. -
Uses of KeyValue in org.apache.pulsar.client.internal
Methods in org.apache.pulsar.client.internal that return KeyValueModifier and TypeMethodDescriptionPulsarClientImplementationBinding.decodeKeyValueSchemaInfo
(SchemaInfo schemaInfo) Decode the key/value schema info to get key schema info and value schema info.Methods in org.apache.pulsar.client.internal that return types with arguments of type KeyValueModifier and TypeMethodDescriptionPulsarClientImplementationBinding.newKeyValueBytesSchema()
PulsarClientImplementationBinding.newKeyValueSchema
(Class<K> key, Class<V> value, SchemaType type) PulsarClientImplementationBinding.newKeyValueSchema
(Schema<K> keySchema, Schema<V> valueSchema) PulsarClientImplementationBinding.newKeyValueSchema
(Schema<K> keySchema, Schema<V> valueSchema, KeyValueEncodingType keyValueEncodingType) Methods in org.apache.pulsar.client.internal with parameters of type KeyValueModifier and TypeMethodDescriptionPulsarClientImplementationBinding.convertKeyValueSchemaInfoDataToString
(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Convert the key/value schema data.PulsarClientImplementationBinding.jsonifyKeyValueSchemaInfo
(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Jsonify the key/value schema info. -
Uses of KeyValue in org.apache.pulsar.common.schema
Methods in org.apache.pulsar.common.schema that return KeyValueModifier and TypeMethodDescriptionstatic <K,
V> KeyValue<K, V> KeyValue.decode
(byte[] data, KeyValue.KeyValueDecoder<K, V> decoder) Decode the value into a key/value pair.KeyValue.KeyValueDecoder.decode
(byte[] keyData, byte[] valueData) Decode key and value bytes into aKeyValue
pair.