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

Interface GenericObject

All Known Subinterfaces:

GenericRecord

public interface GenericObject

This is an abstraction over the logical value that is store into a Message. Pulsar decodes the payload of the Message using the Schema that is configured for the topic.

Method Summary

Modifier and Type	Method	Description
Object	getNativeObject()	Return the internal native representation of the Object, like a AVRO GenericRecord, a String or a byte[].
SchemaType	getSchemaType()	Return the schema tyoe.

Method Details

getSchemaType

SchemaType getSchemaType()

Return the schema tyoe.

Returns:

the schema type

Throws:

UnsupportedOperationException - if this feature is not implemented

See Also:

• when the topic has no schema information
• SchemaType.STRING
• SchemaType.AVRO
• SchemaType.PROTOBUF_NATIVE
• SchemaType.JSON

getNativeObject

Object getNativeObject()

Return the internal native representation of the Object, like a AVRO GenericRecord, a String or a byte[].

Returns:

the decoded object

Throws:

UnsupportedOperationException - if the operation is not supported