Class SimpleRecordTranslator<K,V>

java.lang.Object
org.apache.storm.kafka.spout.SimpleRecordTranslator<K,V>
All Implemented Interfaces:
Serializable, Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>>, RecordTranslator<K,V>

public class SimpleRecordTranslator<K,V> extends Object implements RecordTranslator<K,V>
See Also:
  • Constructor Details

    • SimpleRecordTranslator

      public SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields)
    • SimpleRecordTranslator

      public SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields, String stream)
      Creates a SimpleRecordTranslator.
      Parameters:
      func - The mapping function responsible for translating a Kafka record to a Tuple
      fields - The fields tuples constructed by this translator will contain
      stream - The stream tuples constructed by this translator will target
  • Method Details