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;

Reply via email to