This is an automated email from the ASF dual-hosted git repository. rzo1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push: new c158dee8c STORM-4007 - Add the getName() method in order to obtain the applied label to the Trident stream. c158dee8c is described below commit c158dee8c12aa6547c8037596c797da2f48c348d Author: Alexis LG <alex...@users.noreply.github.com> AuthorDate: Sat Aug 4 11:24:54 2018 +0200 STORM-4007 - Add the getName() method in order to obtain the applied label to the Trident stream. (cherry picked from commit 9b49fb28877d89661da414ac20530b2b7337c38e) --- storm-client/src/jvm/org/apache/storm/trident/Stream.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/storm-client/src/jvm/org/apache/storm/trident/Stream.java b/storm-client/src/jvm/org/apache/storm/trident/Stream.java index d25053d3e..e08e20f5d 100644 --- a/storm-client/src/jvm/org/apache/storm/trident/Stream.java +++ b/storm-client/src/jvm/org/apache/storm/trident/Stream.java @@ -806,6 +806,15 @@ public class Stream implements IAggregatableStream, ResourceDeclarer<Stream> { return this; } + /** + * Returns the label applied to the stream. + * + * @return the label applied to the stream. + */ + public String getName() { + return name; + } + @Override public Fields getOutputFields() { return node.allOutputFields;