DefaultRecordTranslator (Storm 2.7.1 API)

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>
```
public class DefaultRecordTranslator<K,V>
extends Object
implements RecordTranslator<K,V>
```
See Also:

Serialized Form

Field Summary

Fields
Modifier and Type Field Description

static Fields FIELDS
- Fields inherited from interface org.apache.storm.kafka.spout.RecordTranslator
  DEFAULT_STREAM

Constructor Summary

Constructors
Constructor Description

DefaultRecordTranslator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.kafka.spout.RecordTranslator
streams

- Field Detail
  - FIELDS
```
public static final Fields FIELDS
```
- Constructor Detail
  - DefaultRecordTranslator
```
public DefaultRecordTranslator()
```
- Method Detail
  - apply
```
public List<Object> apply(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
```
    Description copied from interface: RecordTranslator
    
    Translate the ConsumerRecord into a list of objects that can be emitted.
    
    Specified by:
    
    apply in interface Func<K,V>
    
    Specified by:
    
    apply in interface RecordTranslator<K,V>
    
    Parameters:
    
    record - the record to translate
    
    Returns:
    
    the objects in the tuple. Return a KafkaTuple 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.
  - getFieldsFor
```
public Fields getFieldsFor(String stream)
```
    Description copied from interface: RecordTranslator
    
    Get the fields associated with a stream. The streams passed in are returned by the RecordTranslator.streams() method.
    
    Specified by:
    
    getFieldsFor in interface RecordTranslator<K,V>
    
    Parameters:
    
    stream - the stream the fields are for
    
    Returns:
    
    the fields for that stream.