storm.kafka.trident.selector

Interface KafkaTopicSelector

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultTopicSelector

public interface KafkaTopicSelector
extends Serializable

Method Summary

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

Method Detail

getTopic

String getTopic(TridentTuple tuple)