Interface | Description |
---|---|
PulsarDeserializationSchema<T> |
A schema bridge for deserializing the pulsar's
Message<byte[]> into a flink managed
instance. |
Class | Description |
---|---|
PulsarDeserializationSchemaInitializationContext |
Convert the
SourceReaderContext into a DeserializationSchema.InitializationContext , we would use a pulsar named metric group for this
content. |
PulsarTypeInformationWrapper<T> |
Wrap the flink TypeInformation into a
PulsarDeserializationSchema . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.