Interface | Description |
---|---|
PulsarSchemaFactory<T> |
The schema factory for a specified
SchemaType . |
Class | Description |
---|---|
PulsarSchema<T> |
A wrapper for Pulsar
Schema , make it serializable and can be created from SchemaInfo . |
PulsarSchemaTypeInformation<T> |
Wrap the pulsar
Schema into a flink TypeInformation . |
PulsarSchemaTypeSerializer<T> |
Wrap the pulsar
Schema into a flink TypeSerializer . |
PulsarSchemaTypeSerializer.PulsarSchemaTypeSerializerSnapshot<T> |
Snapshot for PulsarSchemaTypeSerializer, we only snapshot the SerializablePulsarSchema into
the state.
|
PulsarSchemaUtils |
Util class for pulsar schema.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.