# 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
  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
  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
  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
  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
  Modifier
  Constructor
  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
  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
  Description
  `class`
  `RecordTranslatorSchemeAdapter`
  RecordTranslator that delegates to a Scheme.