Support Date / Timestamp objects (elastic#934)

Added support for handling Date and Timestamp objects - convert to epoch milliseconds
williamrandolph · May 10, 2017 · b7f89a8 · b7f89a8
1 parent c0c963b
commit b7f89a8
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/mr/src/main/java/org/elasticsearch/hadoop/serialization/bulk/AbstractBulkFactory.java b/mr/src/main/java/org/elasticsearch/hadoop/serialization/bulk/AbstractBulkFactory.java
@@ -20,6 +20,7 @@
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Date;
 import java.util.concurrent.Callable;
 
 import org.apache.commons.logging.Log;
@@ -120,6 +121,12 @@ void doWrite(Object value) {
 
                 pool.get().bytes(valueString);
             }
+
+            else if (value instanceof Date) {
+                String valueString = (value == null ? "null": Long.toString(((Date) value).getTime()));
+                pool.get().bytes(valueString);
+            }
+
             else if (value instanceof RawJson) {
                 pool.get().bytes(((RawJson) value).json());
             }
@@ -431,4 +438,4 @@ private List<Object> compact(List<Object> list) {
     protected FieldExtractor getParamExtractor() {
         return paramsExtractor;
     }
-}
+}