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

Packages that use Func

Package	Description
org.apache.storm.kafka.spout

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.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.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.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.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.

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)