Uses of Interface
org.apache.storm.kafka.spout.Func
Packages that use Func
Package
Description
-
Uses of Func in org.apache.storm.flux.examples
Classes in org.apache.storm.flux.examples that implement Func -
Uses of Func in org.apache.storm.kafka.spout
Subinterfaces of Func in org.apache.storm.kafka.spoutModifier and TypeInterfaceDescriptioninterfaceRecordTranslator<K,V> Translate aConsumerRecordto a tuple.Classes in org.apache.storm.kafka.spout that implement FuncModifier and TypeClassDescriptionclassBased off of a given Kafka topic a ConsumerRecord came from it will be translated to a Storm tuple and emitted to a given stream.classclassMethods in org.apache.storm.kafka.spout with parameters of type FuncModifier and TypeMethodDescriptionByTopicRecordTranslator.forTopic(String topic, Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields) Configure a translator for a given topic with tuples to be emitted to the default stream.ByTopicRecordTranslator.forTopic(String topic, Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields, String stream) Configure a translator for a given topic.Constructors in org.apache.storm.kafka.spout with parameters of type FuncModifierConstructorDescriptionByTopicRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields) Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to the default stream.ByTopicRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields, String stream) Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to stream.SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields) SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields, String stream) Creates a SimpleRecordTranslator. -
Uses of Func in org.apache.storm.kafka.spout.internal
Methods in org.apache.storm.kafka.spout.internal with parameters of type FuncModifier and TypeMethodDescriptionCommonKafkaSpoutConfig.Builder.setRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields) Configure a translator with tuples to be emitted on the default stream.CommonKafkaSpoutConfig.Builder.setRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, List<Object>> func, Fields fields, String stream) Configure a translator with tuples to be emitted to a given stream. -
Uses of Func in org.apache.storm.sql.kafka
Classes in org.apache.storm.sql.kafka that implement FuncModifier and TypeClassDescriptionclassRecordTranslator that delegates to a Scheme.