pojo to timestamp field

Author: flashmouse

src/main/java/org/influxdb/annotation/TimeColumn.java

@@ -0,0 +1,13 @@
+package org.influxdb.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+import java.util.concurrent.TimeUnit;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.FIELD)
+public @interface TimeColumn {
+    TimeUnit timeUnit() default TimeUnit.MILLISECONDS;
+}

src/main/java/org/influxdb/dto/Point.java

@@ -5,6 +5,7 @@
 import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.text.NumberFormat;
+import java.time.Instant;
 import java.util.Locale;
 import java.util.Map;
 import java.util.Map.Entry;
@@ -14,6 +15,7 @@
 import org.influxdb.BuilderException;
 import org.influxdb.annotation.Column;
 import org.influxdb.annotation.Measurement;
+import org.influxdb.annotation.TimeColumn;
 import org.influxdb.impl.Preconditions;
 
 /**
@@ -259,6 +261,15 @@ private void addFieldByAttribute(final Object pojo, final Field field, final Col
       try {
         Object fieldValue = field.get(pojo);
 
+        TimeColumn tc = field.getAnnotation(TimeColumn.class);
+        if (tc != null && Instant.class.isAssignableFrom(field.getType())) {
+          Instant instant = (Instant) fieldValue;
+          TimeUnit timeUint = tc.timeUnit();
+          this.time = TimeUnit.MILLISECONDS.convert(instant.toEpochMilli(), timeUint);
+          this.precision = timeUint;
+          return;
+        }
+
         if (column.tag()) {
           this.tags.put(fieldName, (String) fieldValue);
         } else {