## 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 and 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 and 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 and 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
    Constructor and 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 and Description
    --- | ---
    `RecordTranslator<K,V>` | CommonKafkaSpoutConfig.`getTranslator()`

    Methods in org.apache.storm.kafka.spout.internal with parameters of type RecordTranslator
    Modifier and Type | Method and 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 and Description
    --- | ---
    `class` | `RecordTranslatorSchemeAdapter` RecordTranslator that delegates to a Scheme.

Copyright © 2021 The Apache Software Foundation. All rights reserved.