[kafka] branch trunk updated: Minor: add valueChangingOperation and mergeNode to StreamsGraphNode#toString (#5522)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new f9f0b5c  Minor: add valueChangingOperation and mergeNode to StreamsGraphNode#toString (#5522)
f9f0b5c is described below

commit f9f0b5c6755c7481699e67d27fb53e03d1493d12
Author: tedyu <yu...@gmail.com>
AuthorDate: Fri Aug 17 16:13:59 2018 -0700

    Minor: add valueChangingOperation and mergeNode to StreamsGraphNode#toString (#5522)
    
    This PR adds valueChangingOperation and mergeNode to StreamsGraphNode#toString
    
    Reviewers: Matthias J. Sax <ma...@confluent.io>, Bill Bejeck <bi...@confluent.io>, Guozhang Wang <wa...@gmail.com>
---
 .../kafka/streams/kstream/internals/graph/StreamsGraphNode.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphNode.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphNode.java
index fac5923..5bb3649 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphNode.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphNode.java
@@ -140,6 +140,11 @@ public abstract class StreamsGraphNode {
         return "StreamsGraphNode{" +
                "nodeName='" + nodeName + '\'' +
                ", buildPriority=" + buildPriority +
-               " parentNodes=" + Arrays.toString(parentNames) + '}';
+               ", repartitionRequired=" + repartitionRequired +
+               ", hasWrittenToTopology=" + hasWrittenToTopology +
+               ", keyChangingOperation=" + keyChangingOperation +
+               ", valueChangingOperation=" + valueChangingOperation +
+               ", mergeNode=" + mergeNode +
+               ", parentNodes=" + Arrays.toString(parentNames) + '}';
     }
 }