@Internal public class PulsarSchemaWrapper<IN> extends Object implements PulsarSerializationSchema<IN>
Constructor and Description |
---|
PulsarSchemaWrapper(PulsarSchema<IN> pulsarSchema) |
Modifier and Type | Method and Description |
---|---|
PulsarMessage<?> |
serialize(IN element,
PulsarSinkContext sinkContext)
Serializes the given element into bytes and
Schema.BYTES . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
flinkSchema, open, pulsarSchema, pulsarSchema, pulsarSchema
public PulsarSchemaWrapper(PulsarSchema<IN> pulsarSchema)
public PulsarMessage<?> serialize(IN element, PulsarSinkContext sinkContext)
PulsarSerializationSchema
Schema.BYTES
. Or you can convert it to a
new type of instance with a Schema
. The return value PulsarMessage
can be
built by PulsarMessageBuilder
. All the methods provided in the PulsarMessageBuilder
is just equals to the TypedMessageBuilder
.serialize
in interface PulsarSerializationSchema<IN>
element
- Element to be serialized.sinkContext
- Context to provide extra information.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.