Package org.apache.pulsar.client.api.schema

Interface KeyValueSchema<K,V>

Type Parameters:

K - the type of the Key

V - the type of the Value.

All Superinterfaces:

Cloneable, Schema<KeyValue<K,V>>

public interface KeyValueSchema<K,V>
extends Schema<KeyValue<K,V>>

This interface models a Schema that is composed of two parts. A Key and a Value.

Field Summary

Fields inherited from interface org.apache.pulsar.client.api.Schema

BOOL, BYTEBUFFER, BYTES, DATE, DOUBLE, FLOAT, INSTANT, INT16, INT32, INT64, INT8, LOCAL_DATE, LOCAL_DATE_TIME, LOCAL_TIME, STRING, TIME, TIMESTAMP

Method Summary

Modifier and Type	Method	Description
Schema<K>	getKeySchema()	Get the Schema of the Key.
KeyValueEncodingType	getKeyValueEncodingType()	Get the KeyValueEncodingType.
Schema<V>	getValueSchema()	Get the Schema of the Value.

Methods inherited from interface org.apache.pulsar.client.api.Schema

clone, configureSchemaInfo, decode, decode, decode, decode, encode, getNativeSchema, getSchemaInfo, requireFetchingSchemaInfo, setSchemaInfoProvider, supportSchemaVersioning, validate

Method Details

getKeySchema

Schema<K> getKeySchema()

Get the Schema of the Key.

Returns:

the Schema of the Key

getValueSchema

Schema<V> getValueSchema()

Get the Schema of the Value.

Returns:

the Schema of the Value

getKeyValueEncodingType

KeyValueEncodingType getKeyValueEncodingType()

Get the KeyValueEncodingType.

Returns:

the KeyValueEncodingType

See Also:

• KeyValueEncodingType.INLINE
• KeyValueEncodingType.SEPARATED