org.apache.heron.kafka.bolt.selector

Interface KafkaTopicSelector

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultTopicSelector, FieldIndexTopicSelector, FieldNameTopicSelector

public interface KafkaTopicSelector
extends Serializable

Method Summary

Modifier and Type	Method and Description
String	getTopic(org.apache.heron.api.tuple.Tuple tuple)

Method Detail

getTopic

String getTopic(org.apache.heron.api.tuple.Tuple tuple)