You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/11/25 23:53:34 UTC
kafka git commit: MINOR: change KStream processor names
Repository: kafka
Updated Branches:
refs/heads/trunk 8ed271b82 -> e14ae66e7
MINOR: change KStream processor names
guozhangwang
Author: Yasuhiro Matsuda <ya...@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 <ya...@confluent.io>
Authored: Wed Nov 25 14:53:24 2015 -0800
Committer: Guozhang Wang <wa...@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;