You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2016/07/10 06:24:50 UTC
kylin git commit: minor improvement,
set derived time dimension minute_start and hour_start to be
timestamp without millis
Repository: kylin
Updated Branches:
refs/heads/master f30862eb6 -> 03f445307
minor improvement, set derived time dimension minute_start and hour_start to be timestamp without millis
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/03f44530
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/03f44530
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/03f44530
Branch: refs/heads/master
Commit: 03f445307691d07b4222d6dea380457d968c0c70
Parents: f30862e
Author: Hongbin Ma <ma...@apache.org>
Authored: Sun Jul 10 14:24:33 2016 +0800
Committer: Hongbin Ma <ma...@apache.org>
Committed: Sun Jul 10 14:24:33 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/source/kafka/StreamingParser.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/03f44530/source-kafka/src/main/java/org/apache/kylin/source/kafka/StreamingParser.java
----------------------------------------------------------------------
diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/StreamingParser.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/StreamingParser.java
index 5e9f6ae..89b9b56 100644
--- a/source-kafka/src/main/java/org/apache/kylin/source/kafka/StreamingParser.java
+++ b/source-kafka/src/main/java/org/apache/kylin/source/kafka/StreamingParser.java
@@ -94,10 +94,10 @@ public abstract class StreamingParser {
long normalized = 0;
if (columnName.equals("minute_start")) {
normalized = TimeUtil.getMinuteStart(t);
- result.add(DateFormat.formatToTimeStr(normalized));
+ result.add(DateFormat.formatToTimeWithoutMilliStr(normalized));
} else if (columnName.equals("hour_start")) {
normalized = TimeUtil.getHourStart(t);
- result.add(DateFormat.formatToTimeStr(normalized));
+ result.add(DateFormat.formatToTimeWithoutMilliStr(normalized));
} else if (columnName.equals("day_start")) {
//from day_start on, formatTs will output date format
normalized = TimeUtil.getDayStart(t);