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, wait
streams
public static final Fields FIELDS
public List<Object> apply(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
RecordTranslator
Translate 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)
RecordTranslator
Get 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 © 2020 The Apache Software Foundation. All rights reserved.