Uses of Interface
org.apache.storm.kafka.spout.Func

Packages that use Func

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 Func in org.apache.storm.flux.examples

Classes in org.apache.storm.flux.examples that implement Func

Modifier and Type	Class and Description
class	OnlyValueRecordTranslator<K,V>

Uses of Func in org.apache.storm.kafka.spout

Subinterfaces of Func in org.apache.storm.kafka.spout

Modifier and Type	Interface and Description
interface	RecordTranslator<K,V> Translate a ConsumerRecord to a tuple.

Classes in org.apache.storm.kafka.spout that implement Func

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 Func

Modifier and Type	Method and Description
ByTopicRecordTranslator<K,V>	ByTopicRecordTranslator.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<K,V>	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 Func

Constructor and Description
ByTopicRecordTranslator(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 Func

Modifier and Type	Method and Description
T	CommonKafkaSpoutConfig.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.
T	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 Func

Modifier and Type	Class and Description
class	RecordTranslatorSchemeAdapter RecordTranslator that delegates to a Scheme.