Package org.apache.storm.kafka.spout
Class DefaultRecordTranslator<K,V> 
java.lang.Object
org.apache.storm.kafka.spout.DefaultRecordTranslator<K,V> 
- All Implemented Interfaces:
- Serializable,- Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,,- V>, - List<Object>> - RecordTranslator<K,- V> 
- See Also:
- 
Field SummaryFieldsFields inherited from interface org.apache.storm.kafka.spout.RecordTranslatorDEFAULT_STREAM
- 
Constructor SummaryConstructors
- 
Method SummaryMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.kafka.spout.RecordTranslatorstreams
- 
Field Details- 
FIELDS
 
- 
- 
Constructor Details- 
DefaultRecordTranslatorpublic DefaultRecordTranslator()
 
- 
- 
Method Details- 
applyDescription copied from interface:RecordTranslatorTranslate the ConsumerRecord into a list of objects that can be emitted.- Specified by:
- applyin interface- Func<K,- V> 
- Specified by:
- applyin interface- RecordTranslator<K,- V> 
- Parameters:
- record- the record to translate
- Returns:
- the objects in the tuple.  Return a KafkaTupleif you want to route the tuple to a non-default stream. Returnnullto discard an invalidConsumerRecordifKafkaSpoutConfig.Builder.setEmitNullTuples(boolean)is set tofalse.
 
- 
getFieldsForDescription copied from interface:RecordTranslatorGet the fields associated with a stream. The streams passed in are returned by theRecordTranslator.streams()method.- Specified by:
- getFieldsForin interface- RecordTranslator<K,- V> 
- Parameters:
- stream- the stream the fields are for
- Returns:
- the fields for that stream.
 
 
-