KYLIN-1417 Change to use TreeMap to allow null as value Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/3c390deb Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/3c390deb Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/3c390deb
Branch: refs/heads/1.4-rc Commit: 3c390deb398836423bf69455cc785baddcf87b17 Parents: 9e3fd7a Author: shaofengshi <shaofeng...@apache.org> Authored: Tue Feb 16 10:29:47 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Tue Feb 16 10:29:47 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/source/kafka/TimedJsonStreamParser.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/3c390deb/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java ---------------------------------------------------------------------- diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java index 65835cd..05f94d8 100644 --- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java +++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/TimedJsonStreamParser.java @@ -35,11 +35,7 @@ package org.apache.kylin.source.kafka; import java.io.IOException; -import java.util.ArrayList; -import java.util.Collections; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentSkipListMap; @@ -105,7 +101,7 @@ public final class TimedJsonStreamParser extends StreamingParser { public StreamingMessage parse(MessageAndOffset messageAndOffset) { try { Map<String, String> message = mapper.readValue(new ByteBufferBackedInputStream(messageAndOffset.message().payload()), mapType); - ConcurrentMap<String, String> root = new ConcurrentSkipListMap<String, String>(String.CASE_INSENSITIVE_ORDER); + Map<String, String> root = new TreeMap<String, String>(String.CASE_INSENSITIVE_ORDER); root.putAll(message); String tsStr = root.get(tsColName);
