# Uses of Interface
org.apache.storm.kafka.spout.RecordTranslator

Packages that use RecordTranslator
Package
Description
org.apache.storm.flux.examples
org.apache.storm.kafka.spout
org.apache.storm.kafka.spout.internal
org.apache.storm.sql.kafka

- ## Uses of RecordTranslator in org.apache.storm.flux.examples

  Classes in org.apache.storm.flux.examples that implement RecordTranslator
  Modifier and Type
  Class
  Description
  `class`
  `OnlyValueRecordTranslator<K,V>`

- ## Uses of RecordTranslator in org.apache.storm.kafka.spout

  Classes in org.apache.storm.kafka.spout that implement RecordTranslator
  Modifier and Type
  Class
  Description
  `class`
  `ByTopicRecordTranslator<K,V>`
  Based off of a given Kafka topic a ConsumerRecord came from it will be translated to a Storm tuple and emitted to a given stream.
  `class`
  `DefaultRecordTranslator<K,V>`
  `class`
  `SimpleRecordTranslator<K,V>`
  Methods in org.apache.storm.kafka.spout with parameters of type RecordTranslator
  Modifier and Type
  Method
  Description
  `ByTopicRecordTranslator<K,V>`
  ByTopicRecordTranslator.`forTopic(String topic, RecordTranslator<K,V> translator)`
  Configure a translator for a given kafka topic.
  Constructors in org.apache.storm.kafka.spout with parameters of type RecordTranslator
  Modifier
  Constructor
  Description
  ``
  `ByTopicRecordTranslator(RecordTranslator<K,V> defaultTranslator)`
  Create a record translator with the given default translator.

- ## Uses of RecordTranslator in org.apache.storm.kafka.spout.internal

  Methods in org.apache.storm.kafka.spout.internal that return RecordTranslator
  Modifier and Type
  Method
  Description
  `RecordTranslator<K,V>`
  CommonKafkaSpoutConfig.`getTranslator()`
  Methods in org.apache.storm.kafka.spout.internal with parameters of type RecordTranslator
  Modifier and Type
  Method
  Description
  `T`
  CommonKafkaSpoutConfig.Builder.`setRecordTranslator(RecordTranslator<K,V> translator)`

- ## Uses of RecordTranslator in org.apache.storm.sql.kafka

  Classes in org.apache.storm.sql.kafka that implement RecordTranslator
  Modifier and Type
  Class
  Description
  `class`
  `RecordTranslatorSchemeAdapter`
  RecordTranslator that delegates to a Scheme.