public class DefaultTopicSelector extends Object implements TopicSelector
| Constructor and Description |
|---|
DefaultTopicSelector(String topicName) |
DefaultTopicSelector(String topicName,
String tagName) |
public DefaultTopicSelector(String topicName)
public String getTopic(ITuple tuple)
getTopic in interface TopicSelectorpublic String getTag(ITuple tuple)
getTag in interface TopicSelectorCopyright © 2021 The Apache Software Foundation. All rights reserved.