Uses of Interface
org.apache.storm.kafka.spout.RecordTranslator
Packages that use RecordTranslator
Package
Description
-
Uses of RecordTranslator in org.apache.storm.flux.examples
Classes in org.apache.storm.flux.examples that implement RecordTranslator -
Uses of RecordTranslator in org.apache.storm.kafka.spout
Classes in org.apache.storm.kafka.spout that implement RecordTranslatorModifier and TypeClassDescriptionclass
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
class
Methods in org.apache.storm.kafka.spout with parameters of type RecordTranslatorModifier and TypeMethodDescriptionByTopicRecordTranslator.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 RecordTranslatorModifierConstructorDescriptionByTopicRecordTranslator
(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 RecordTranslatorMethods in org.apache.storm.kafka.spout.internal with parameters of type RecordTranslatorModifier and TypeMethodDescriptionCommonKafkaSpoutConfig.Builder.setRecordTranslator
(RecordTranslator<K, V> translator) -
Uses of RecordTranslator in org.apache.storm.sql.kafka
Classes in org.apache.storm.sql.kafka that implement RecordTranslatorModifier and TypeClassDescriptionclass
RecordTranslator that delegates to a Scheme.