Package org.apache.storm.kafka.trident.selector

Class DefaultTopicSelector

java.lang.Object

org.apache.storm.kafka.trident.selector.DefaultTopicSelector

All Implemented Interfaces:

Serializable, KafkaTopicSelector

public class DefaultTopicSelector
extends Object
implements KafkaTopicSelector

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultTopicSelector(String topicName)

Method Summary

Modifier and Type	Method	Description
String	getTopic(TridentTuple tuple)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultTopicSelector

public DefaultTopicSelector(String topicName)

Method Details

getTopic

public String getTopic(TridentTuple tuple)

Specified by:

getTopic in interface KafkaTopicSelector