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 and Description
DefaultTopicSelector(String topicName)

Method Summary

Modifier and Type	Method and Description
String	getTopic(TridentTuple tuple)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTopicSelector

public DefaultTopicSelector(String topicName)

Method Detail

getTopic

public String getTopic(TridentTuple tuple)

Specified by:

getTopic in interface KafkaTopicSelector