Modifier and Type | Class and Description |
---|---|
class |
PulsarSinkContextImpl
An implementation that would contain all the required context.
|
Modifier and Type | Method and Description |
---|---|
long |
FixedMessageDelayer.deliverAt(IN message,
PulsarSinkContext sinkContext) |
long |
MessageDelayer.deliverAt(IN message,
PulsarSinkContext sinkContext)
Return the send time for this message.
|
Modifier and Type | Method and Description |
---|---|
String |
RoundRobinTopicRouter.route(IN in,
String key,
List<String> partitions,
PulsarSinkContext context) |
String |
KeyHashTopicRouter.route(IN in,
String key,
List<String> partitions,
PulsarSinkContext context) |
String |
TopicRouter.route(IN in,
String key,
List<String> partitions,
PulsarSinkContext context)
Choose the topic by given record & available partition list.
|
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.
|
PulsarMessage<?> |
PulsarSerializationSchemaWrapper.serialize(IN element,
PulsarSinkContext sinkContext) |
PulsarMessage<?> |
PulsarSerializationSchema.serialize(IN element,
PulsarSinkContext sinkContext)
Serializes the given element into bytes and
Schema.BYTES . |
PulsarMessage<?> |
PulsarSchemaWrapper.serialize(IN element,
PulsarSinkContext sinkContext) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.