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>

public class DefaultRecordTranslator<K,V>
extends Object
implements RecordTranslator<K,V>

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final Fields	FIELDS

Fields inherited from interface org.apache.storm.kafka.spout.RecordTranslator

DEFAULT_STREAM

Constructor Summary

Constructors

Constructor	Description
DefaultRecordTranslator()

Method Summary

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 Details

FIELDS

public static final Fields FIELDS

Constructor Details

DefaultRecordTranslator

public DefaultRecordTranslator()

Method Details

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.