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 TopicSelector
public String getTag(ITuple tuple)
getTag
in interface TopicSelector
Copyright © 2020 The Apache Software Foundation. All rights reserved.