org.apache.flink.connector.pulsar.common.schema

Interface PulsarSchemaFactory<T>

All Known Implementing Classes:

AvroSchemaFactory, BaseStructSchemaFactory, JSONSchemaFactory, KeyValueSchemaFactory, PrimitiveSchemaFactory, ProtobufNativeSchemaFactory, ProtobufSchemaFactory, StringSchemaFactory

@Internal
public interface PulsarSchemaFactory<T>

The schema factory for a specified SchemaType. We add this factory because of pulsar don't provide a serializable schema and we can't create it directly from SchemaInfo. So we have to implement this creation logic.

Method Summary

Modifier and Type	Method and Description
org.apache.pulsar.client.api.Schema<T>	createSchema(org.apache.pulsar.common.schema.SchemaInfo info) Create the schema by the given info.
TypeInformation<T>	createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info) Create the flink type information by the given schema info.
org.apache.pulsar.common.schema.SchemaType	type() The supported schema type for this factory.

Method Detail

type

org.apache.pulsar.common.schema.SchemaType type()

The supported schema type for this factory. We would classify the factory by the type.

createSchema

org.apache.pulsar.client.api.Schema<T> createSchema(org.apache.pulsar.common.schema.SchemaInfo info)

Create the schema by the given info.

createTypeInfo

TypeInformation<T> createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info)

Create the flink type information by the given schema info.