增加micro 时间戳

gf53520 · Jul 18, 2018 · 68981c8 · 68981c8
1 parent d834aae
commit 68981c8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/java-util/src/main/java/io/druid/java/util/common/parsers/TimestampParser.java b/java-util/src/main/java/io/druid/java/util/common/parsers/TimestampParser.java
@@ -72,6 +72,7 @@ public static Function<String, DateTime> createTimestampParser(
       };
     } else if (format.equalsIgnoreCase("posix")
         || format.equalsIgnoreCase("millis")
+        || format.equalsIgnoreCase("micro")
         || format.equalsIgnoreCase("nano")) {
       final Function<Number, DateTime> numericFun = createNumericTimestampParser(format);
       return input -> {
@@ -106,6 +107,8 @@ public static Function<Number, DateTime> createNumericTimestampParser(
     // Ignore millis for ruby
     if (format.equalsIgnoreCase("posix") || format.equalsIgnoreCase("ruby")) {
       return input -> DateTimes.utc(TimeUnit.SECONDS.toMillis(input.longValue()));
+    } else if (format.equalsIgnoreCase("micro")) {
+      return input -> DateTimes.utc(TimeUnit.MICROSECONDS.toMillis(input.longValue()));
     } else if (format.equalsIgnoreCase("nano")) {
       return input -> DateTimes.utc(TimeUnit.NANOSECONDS.toMillis(input.longValue()));
     } else {