public class SimpleRecordTranslator<K,V> extends Object implements RecordTranslator<K,V>
DEFAULT_STREAM
Constructor and Description |
---|
SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func,
Fields fields) |
SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func,
Fields fields,
String stream) |
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.
|
List<String> |
streams() |
public SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, 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 truepublic 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 © 2022 The Apache Software Foundation. All Rights Reserved.