Constructor and Description |
---|
PulsarCommitter(SinkConfiguration sinkConfiguration) |
Modifier and Type | Method and Description |
---|---|
static <T> org.apache.pulsar.client.api.ProducerBuilder<T> |
PulsarSinkConfigUtils.createProducerBuilder(org.apache.pulsar.client.api.PulsarClient client,
org.apache.pulsar.client.api.Schema<T> schema,
SinkConfiguration configuration)
Create a pulsar producer builder by using the given Configuration.
|
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.
|
Constructor and Description |
---|
PulsarSinkContextImpl(Sink.InitContext initContext,
SinkConfiguration sinkConfiguration) |
Modifier and Type | Method and Description |
---|---|
default void |
MessageDelayer.open(SinkConfiguration sinkConfiguration)
Implement this method if you have some non-serializable field.
|
Modifier and Type | Method and Description |
---|---|
default void |
TopicRouter.open(SinkConfiguration sinkConfiguration)
Implement this method if you have some non-serializable field.
|
Constructor and Description |
---|
KeyHashTopicRouter(SinkConfiguration sinkConfiguration) |
RoundRobinTopicRouter(SinkConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
PulsarSerializationSchemaWrapper.open(SerializationSchema.InitializationContext initializationContext,
PulsarSinkContext sinkContext,
SinkConfiguration sinkConfiguration) |
default void |
PulsarSerializationSchema.open(SerializationSchema.InitializationContext initializationContext,
PulsarSinkContext sinkContext,
SinkConfiguration sinkConfiguration)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
TopicMetadataListener.open(SinkConfiguration sinkConfiguration,
ProcessingTimeService timeService)
Register the topic metadata update in process time service.
|
Constructor and Description |
---|
TopicProducerRegister(SinkConfiguration sinkConfiguration) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.