Uses of Interface
org.apache.pulsar.common.schema.SchemaInfo
Package
Description
Pulsar Client API.
Schema definitions for 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 SchemaInfo in org.apache.pulsar.client.api
Modifier and TypeMethodDescriptiondefault void
Schema.configureSchemaInfo
(String topic, String componentName, SchemaInfo schemaInfo) Configure the schema to use the provided schema info.static GenericSchema<GenericRecord>
Schema.generic
(SchemaInfo schemaInfo) Returns a generic schema of existing schema info.static Schema<?>
Schema.getSchema
(SchemaInfo schemaInfo) -
Uses of SchemaInfo in org.apache.pulsar.client.api.schema
Modifier and TypeMethodDescriptionRecordSchemaBuilder.build
(SchemaType schemaType) Build the schema info.Modifier and TypeMethodDescriptionSchemaInfoProvider.getLatestSchema()
Retrieve the latest schema info.SchemaInfoProvider.getSchemaByVersion
(byte[] schemaVersion) Retrieve the schema info of a given schemaVersion.Modifier and TypeMethodDescriptionstatic GenericSchema
GenericSchema.of
(SchemaInfo schemaInfo) static GenericSchema
GenericSchema.of
(SchemaInfo schemaInfo, boolean useProvidedSchemaAsReaderSchema) -
Uses of SchemaInfo in org.apache.pulsar.client.internal
Modifier and TypeMethodDescription<K,
V> SchemaInfo PulsarClientImplementationBinding.encodeKeyValueSchemaInfo
(String schemaName, Schema<K> keySchema, Schema<V> valueSchema, KeyValueEncodingType keyValueEncodingType) Encode key & value into schema into a KeyValue schema.<K,
V> SchemaInfo PulsarClientImplementationBinding.encodeKeyValueSchemaInfo
(Schema<K> keySchema, Schema<V> valueSchema, KeyValueEncodingType keyValueEncodingType) Encode key & value into schema into a KeyValue schema.PulsarClientImplementationBinding.newSchemaInfoImpl
(String name, byte[] schema, SchemaType type, long timestamp, Map<String, String> propertiesValue) Modifier and TypeMethodDescriptionPulsarClientImplementationBinding.decodeKeyValueSchemaInfo
(SchemaInfo schemaInfo) Decode the key/value schema info to get key schema info and value schema info.PulsarClientImplementationBinding.decodeKeyValueSchemaInfo
(SchemaInfo schemaInfo) Decode the key/value schema info to get key schema info and value schema info.Modifier and TypeMethodDescriptionPulsarClientImplementationBinding.decodeKeyValueEncodingType
(SchemaInfo schemaInfo) Decode the kv encoding type from the schema info.PulsarClientImplementationBinding.decodeKeyValueSchemaInfo
(SchemaInfo schemaInfo) Decode the key/value schema info to get key schema info and value schema info.PulsarClientImplementationBinding.getGenericSchema
(SchemaInfo schemaInfo) Schema<?>
PulsarClientImplementationBinding.getSchema
(SchemaInfo schemaInfo) PulsarClientImplementationBinding.jsonifySchemaInfo
(SchemaInfo schemaInfo) Jsonify the schema info.Modifier and TypeMethodDescriptionPulsarClientImplementationBinding.convertKeyValueSchemaInfoDataToString
(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Convert the key/value schema data.PulsarClientImplementationBinding.convertKeyValueSchemaInfoDataToString
(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Convert the key/value schema data.PulsarClientImplementationBinding.jsonifyKeyValueSchemaInfo
(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Jsonify the key/value schema info.PulsarClientImplementationBinding.jsonifyKeyValueSchemaInfo
(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Jsonify the key/value schema info. -
Uses of SchemaInfo in org.apache.pulsar.common.schema