Package | Description |
---|---|
org.apache.flink.connector.pulsar.common.schema | |
org.apache.flink.connector.pulsar.sink.writer.serializer |
Constructor and Description |
---|
PulsarSchemaTypeInformation(PulsarSchema<T> schema) |
PulsarSchemaTypeSerializer(PulsarSchema<T> schema) |
PulsarSchemaTypeSerializerSnapshot(PulsarSchema<T> schema) |
Constructor and Description |
---|
PulsarSchemaWrapper(PulsarSchema<IN> pulsarSchema) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.