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 <[email protected]>
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;