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.