kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: change KStream processor names
Date Wed, 25 Nov 2015 22:53:34 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 8ed271b82 -> e14ae66e7


MINOR: change KStream processor names

guozhangwang

Author: Yasuhiro Matsuda <yasuhiro@confluent.io>

Reviewers: Guozhang Wang

Closes #587 from ymatsuda/kstream_processor_names


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e14ae66e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e14ae66e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e14ae66e

Branch: refs/heads/trunk
Commit: e14ae66e721f98ca7c18d35ea022e6de733f4c03
Parents: 8ed271b
Author: Yasuhiro Matsuda <yasuhiro@confluent.io>
Authored: Wed Nov 25 14:53:24 2015 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Wed Nov 25 14:53:24 2015 -0800

----------------------------------------------------------------------
 .../streams/kstream/internals/KStreamImpl.java  | 32 ++++++++++----------
 1 file changed, 16 insertions(+), 16 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/e14ae66e/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
index 1ac23b2..a408458 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
@@ -38,37 +38,37 @@ import java.util.Set;
 
 public class KStreamImpl<K, V> implements KStream<K, V> {
 
-    private static final String FILTER_NAME = "KAFKA-FILTER-";
+    private static final String FILTER_NAME = "KSTREAM-FILTER-";
 
-    private static final String MAP_NAME = "KAFKA-MAP-";
+    private static final String MAP_NAME = "KSTREAM-MAP-";
 
-    private static final String MAPVALUES_NAME = "KAFKA-MAPVALUES-";
+    private static final String MAPVALUES_NAME = "KSTREAM-MAPVALUES-";
 
-    private static final String FLATMAP_NAME = "KAFKA-FLATMAP-";
+    private static final String FLATMAP_NAME = "KSTREAM-FLATMAP-";
 
-    private static final String FLATMAPVALUES_NAME = "KAFKA-FLATMAPVALUES-";
+    private static final String FLATMAPVALUES_NAME = "KSTREAM-FLATMAPVALUES-";
 
-    private static final String TRANSFORM_NAME = "KAFKA-TRANSFORM-";
+    private static final String TRANSFORM_NAME = "KSTREAM-TRANSFORM-";
 
-    private static final String TRANSFORMVALUES_NAME = "KAFKA-TRANSFORMVALUES-";
+    private static final String TRANSFORMVALUES_NAME = "KSTREAM-TRANSFORMVALUES-";
 
-    private static final String PROCESSOR_NAME = "KAFKA-PROCESSOR-";
+    private static final String PROCESSOR_NAME = "KSTREAM-PROCESSOR-";
 
-    private static final String BRANCH_NAME = "KAFKA-BRANCH-";
+    private static final String BRANCH_NAME = "KSTREAM-BRANCH-";
 
-    private static final String BRANCHCHILD_NAME = "KAFKA-BRANCHCHILD-";
+    private static final String BRANCHCHILD_NAME = "KSTREAM-BRANCHCHILD-";
 
-    private static final String WINDOWED_NAME = "KAFKA-WINDOWED-";
+    private static final String WINDOWED_NAME = "KSTREAM-WINDOWED-";
 
-    private static final String SINK_NAME = "KAFKA-SINK-";
+    private static final String SINK_NAME = "KSTREAM-SINK-";
 
-    public static final String JOINTHIS_NAME = "KAFKA-JOINTHIS-";
+    public static final String JOINTHIS_NAME = "KSTREAM-JOINTHIS-";
 
-    public static final String JOINOTHER_NAME = "KAFKA-JOINOTHER-";
+    public static final String JOINOTHER_NAME = "KSTREAM-JOINOTHER-";
 
-    public static final String MERGE_NAME = "KAFKA-MERGE-";
+    public static final String MERGE_NAME = "KSTREAM-MERGE-";
 
-    public static final String SOURCE_NAME = "KAFKA-SOURCE-";
+    public static final String SOURCE_NAME = "KSTREAM-SOURCE-";
 
     protected final KStreamBuilder topology;
     public final String name;


Mime
View raw message