Class FieldNameTopicSelector

java.lang.Object
org.apache.storm.kafka.bolt.selector.FieldNameTopicSelector
All Implemented Interfaces:
Serializable, KafkaTopicSelector

public class FieldNameTopicSelector extends Object implements KafkaTopicSelector
Uses field name to select topic name from tuple .
See Also: