Package org.apache.storm.kafka.bolt.selector

# Class FieldIndexTopicSelector

java.lang.Object
org.apache.storm.kafka.bolt.selector.FieldIndexTopicSelector

All Implemented Interfaces:
  `Serializable`, `KafkaTopicSelector`

public class FieldIndexTopicSelector extends Object implements KafkaTopicSelector
Uses field with a given index to select the topic name from a tuple .

See Also:
  - Serialized Form

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `FieldIndexTopicSelector(int fieldIndex, String defaultTopicName)`
  Creates a new FieldIndexTopicSelector.

- ## Method Summary

  Modifier and Type
  Method
  Description
  `String`
  `getTopic(Tuple tuple)`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Constructor Details

  - ### FieldIndexTopicSelector

    public FieldIndexTopicSelector(int fieldIndex, String defaultTopicName)
    Creates a new FieldIndexTopicSelector.
    Parameters:
      `fieldIndex` - The index of the field containing the topic name
      `defaultTopicName` - The default topic name if the topic name cannot be read from the tuple

- ## Method Details

  - ### getTopic

    public String getTopic(Tuple tuple)
    Specified by:
      `getTopic` in interface `KafkaTopicSelector`