Repository: kafka Updated Branches: refs/heads/trunk 8ed271b82 -> e14ae66e7
MINOR: change KStream processor names guozhangwang Author: Yasuhiro Matsuda <[email protected]> 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 <[email protected]> Authored: Wed Nov 25 14:53:24 2015 -0800 Committer: Guozhang Wang <[email protected]> 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;
