Package | Description |
---|---|
org.apache.flink.connector.pulsar.sink | |
org.apache.flink.connector.pulsar.sink.writer | |
org.apache.flink.connector.pulsar.sink.writer.serializer |
Modifier and Type | Method and Description |
---|---|
<T extends IN> |
PulsarSinkBuilder.setSerializationSchema(PulsarSerializationSchema<T> serializationSchema)
Sets the
PulsarSerializationSchema that transforms incoming records to bytes. |
Constructor and Description |
---|
PulsarWriter(SinkConfiguration sinkConfiguration,
PulsarSerializationSchema<IN> serializationSchema,
TopicMetadataListener metadataListener,
TopicRouter<IN> topicRouter,
MessageDelayer<IN> messageDelayer,
Sink.InitContext initContext)
Constructor creating a Pulsar writer.
|
Modifier and Type | Class and Description |
---|---|
class |
PulsarSchemaWrapper<IN>
Wrap the Pulsar's Schema into PulsarSerializationSchema.
|
class |
PulsarSerializationSchemaWrapper<IN>
Wrap the Flink's SerializationSchema into PulsarSerializationSchema.
|
Modifier and Type | Method and Description |
---|---|
static <T> PulsarSerializationSchema<T> |
PulsarSerializationSchema.flinkSchema(SerializationSchema<T> serializationSchema)
Create a PulsarSerializationSchema by using the flink's
SerializationSchema . |
static <K,V> PulsarSerializationSchema<org.apache.pulsar.common.schema.KeyValue<K,V>> |
PulsarSerializationSchema.pulsarSchema(org.apache.pulsar.client.api.Schema<org.apache.pulsar.common.schema.KeyValue<K,V>> schema,
Class<K> keyClass,
Class<V> valueClass)
Create a PulsarSerializationSchema by using the Pulsar
Schema instance. |
static <T> PulsarSerializationSchema<T> |
PulsarSerializationSchema.pulsarSchema(org.apache.pulsar.client.api.Schema<T> schema)
Create a PulsarSerializationSchema by using the Pulsar
Schema instance. |
static <T> PulsarSerializationSchema<T> |
PulsarSerializationSchema.pulsarSchema(org.apache.pulsar.client.api.Schema<T> schema,
Class<T> typeClass)
Create a PulsarSerializationSchema by using the Pulsar
Schema instance. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.