Uses of Interface
org.apache.storm.kafka.spout.Func
Package
Description
-
Uses of Func in org.apache.storm.flux.examples
-
Uses of Func in org.apache.storm.kafka.spout
Modifier and TypeInterfaceDescriptioninterface
RecordTranslator<K,
V> Translate aConsumerRecord
to a tuple.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, 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.ModifierConstructorDescriptionByTopicRecordTranslator
(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
Modifier 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
Modifier and TypeClassDescriptionclass
RecordTranslator that delegates to a Scheme.