public interface TopicSelector extends Serializable
String
getTag(ITuple tuple)
getTopic(ITuple tuple)
String getTopic(ITuple tuple)
String getTag(ITuple tuple)
Copyright © 2022 The Apache Software Foundation. All rights reserved.