Uses of Class
org.apache.pulsar.common.schema.SchemaInfo
Packages that use SchemaInfo
Package
Description
Pulsar Client API.
Schema definitions for Pulsar Client API.
Helpers which provide useful functionality for the implementation of Pulsar Client API.
-
Uses of SchemaInfo in org.apache.pulsar.client.api
Methods in org.apache.pulsar.client.api that return SchemaInfoMethods in org.apache.pulsar.client.api with parameters of type SchemaInfoModifier and TypeMethodDescriptiondefault voidSchema.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
Methods in org.apache.pulsar.client.api.schema that return SchemaInfoModifier and TypeMethodDescriptionRecordSchemaBuilder.build(SchemaType schemaType) Build the schema info.Methods in org.apache.pulsar.client.api.schema that return types with arguments of type SchemaInfoModifier and TypeMethodDescriptionSchemaInfoProvider.getLatestSchema()Retrieve the latest schema info.SchemaInfoProvider.getSchemaByVersion(byte[] schemaVersion) Retrieve the schema info of a given schemaVersion. -
Uses of SchemaInfo in org.apache.pulsar.client.internal
Methods in org.apache.pulsar.client.internal that return SchemaInfoModifier and TypeMethodDescriptionstatic <K,V> SchemaInfo DefaultImplementation.encodeKeyValueSchemaInfo(String schemaName, Schema<K> keySchema, Schema<V> valueSchema, KeyValueEncodingType keyValueEncodingType) Encode key & value into schema into a KeyValue schema.static <K,V> SchemaInfo DefaultImplementation.encodeKeyValueSchemaInfo(Schema<K> keySchema, Schema<V> valueSchema, KeyValueEncodingType keyValueEncodingType) Encode key & value into schema into a KeyValue schema.Methods in org.apache.pulsar.client.internal that return types with arguments of type SchemaInfoModifier and TypeMethodDescriptionstatic KeyValue<SchemaInfo,SchemaInfo> DefaultImplementation.decodeKeyValueSchemaInfo(SchemaInfo schemaInfo) Decode the key/value schema info to get key schema info and value schema info.static KeyValue<SchemaInfo,SchemaInfo> DefaultImplementation.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 with parameters of type SchemaInfoModifier and TypeMethodDescriptionstatic KeyValueEncodingTypeDefaultImplementation.decodeKeyValueEncodingType(SchemaInfo schemaInfo) Decode the kv encoding type from the schema info.static KeyValue<SchemaInfo,SchemaInfo> DefaultImplementation.decodeKeyValueSchemaInfo(SchemaInfo schemaInfo) Decode the key/value schema info to get key schema info and value schema info.static GenericSchema<GenericRecord>DefaultImplementation.getGenericSchema(SchemaInfo schemaInfo) static Schema<?>DefaultImplementation.getSchema(SchemaInfo schemaInfo) static StringDefaultImplementation.jsonifySchemaInfo(SchemaInfo schemaInfo) Jsonify the schema info.Method parameters in org.apache.pulsar.client.internal with type arguments of type SchemaInfoModifier and TypeMethodDescriptionstatic StringDefaultImplementation.convertKeyValueSchemaInfoDataToString(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Convert the key/value schema data.static StringDefaultImplementation.convertKeyValueSchemaInfoDataToString(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Convert the key/value schema data.static StringDefaultImplementation.jsonifyKeyValueSchemaInfo(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Jsonify the key/value schema info.static StringDefaultImplementation.jsonifyKeyValueSchemaInfo(KeyValue<SchemaInfo, SchemaInfo> kvSchemaInfo) Jsonify the key/value schema info.