Package org.apache.pulsar.functions.api

Interface KVRecord<K,V>

All Superinterfaces:

Record

@Public
@Stable
public interface KVRecord<K,V>
extends Record

key value schema record.

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.client.api.Schema<K>	getKeySchema()
org.apache.pulsar.common.schema.KeyValueEncodingType	getKeyValueEncodingType()
org.apache.pulsar.client.api.Schema<V>	getValueSchema()

Methods inherited from interface org.apache.pulsar.functions.api.Record

ack, fail, getDestinationTopic, getEventTime, getKey, getMessage, getPartitionId, getPartitionIndex, getProperties, getRecordSequence, getSchema, getTopicName, getValue

Method Details

getKeySchema

org.apache.pulsar.client.api.Schema<K> getKeySchema()

getValueSchema

org.apache.pulsar.client.api.Schema<V> getValueSchema()

getKeyValueEncodingType

org.apache.pulsar.common.schema.KeyValueEncodingType getKeyValueEncodingType()