Package | Description |
---|---|
org.apache.flink.connector.pulsar.sink.writer.message | |
org.apache.flink.connector.pulsar.sink.writer.serializer |
Modifier and Type | Method and Description |
---|---|
PulsarMessage<T> |
PulsarMessageBuilder.build() |
Modifier and Type | Method and Description |
---|---|
PulsarMessage<?> |
PulsarSchemaWrapper.serialize(IN element,
PulsarSinkContext sinkContext) |
PulsarMessage<?> |
PulsarSerializationSchemaWrapper.serialize(IN element,
PulsarSinkContext sinkContext) |
PulsarMessage<?> |
PulsarSerializationSchema.serialize(IN element,
PulsarSinkContext sinkContext)
Serializes the given element into bytes and
Schema.BYTES . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.