public class DefaultRecordTranslator<K,V> extends Object implements RecordTranslator<K,V>
| Modifier and Type | Field and Description |
|---|---|
static Fields |
FIELDS |
DEFAULT_STREAM| Constructor and Description |
|---|
DefaultRecordTranslator() |
| Modifier and Type | Method and Description |
|---|---|
List<Object> |
apply(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
Translate the ConsumerRecord into a list of objects that can be emitted.
|
Fields |
getFieldsFor(String stream)
Get the fields associated with a stream.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitstreamspublic static final Fields FIELDS
public List<Object> apply(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
RecordTranslatorTranslate the ConsumerRecord into a list of objects that can be emitted.
apply in interface Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>>apply in interface RecordTranslator<K,V>record - the record to translateKafkaTuple if you want to route the tuple to a non-default stream. Return null to discard an invalid ConsumerRecord if KafkaSpoutConfig.Builder.setEmitNullTuples(boolean) is set to false.public Fields getFieldsFor(String stream)
RecordTranslatorGet the fields associated with a stream. The streams passed in are returned by the RecordTranslator.streams() method.
getFieldsFor in interface RecordTranslator<K,V>stream - the stream the fields are forCopyright © 2021 The Apache Software Foundation. All rights reserved.