T
- The deserialized pulsar message type, aka the source message type.public class PulsarMessageCollector<T> extends Object implements Collector<T>
Collector
for accepting the deserialized PulsarMessage
from pulsar PulsarDeserializationSchema
.Constructor and Description |
---|
PulsarMessageCollector(String splitId,
RecordsBySplits.Builder<PulsarMessage<T>> builder) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the collector.
|
void |
collect(T t)
Emits a record.
|
void |
setMessage(org.apache.pulsar.client.api.Message<?> message) |
public PulsarMessageCollector(String splitId, RecordsBySplits.Builder<PulsarMessage<T>> builder)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.