## 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.

Copyright © 2019 The Apache Software Foundation. All rights reserved.