Uses of Interface
org.apache.storm.kafka.spout.RecordTranslator
Package
Description
-
Uses of RecordTranslator in org.apache.storm.flux.examples
-
Uses of RecordTranslator in org.apache.storm.kafka.spout
Modifier 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
Modifier and TypeMethodDescriptionByTopicRecordTranslator.forTopic
(String topic, RecordTranslator<K, V> translator) Configure a translator for a given kafka topic.ModifierConstructorDescriptionByTopicRecordTranslator
(RecordTranslator<K, V> defaultTranslator) Create a record translator with the given default translator. -
Uses of RecordTranslator in org.apache.storm.kafka.spout.internal
Modifier and TypeMethodDescriptionCommonKafkaSpoutConfig.Builder.setRecordTranslator
(RecordTranslator<K, V> translator) -
Uses of RecordTranslator in org.apache.storm.sql.kafka
Modifier and TypeClassDescriptionclass
RecordTranslator that delegates to a Scheme.