Selaa lähdekoodia

ES支持Long转日期

AE86 7 kuukautta sitten
vanhempi
säilyke
c73844be23

+ 4 - 0
dbsyncer-connector/dbsyncer-connector-elasticsearch/src/main/java/org/dbsyncer/connector/elasticsearch/schema/ESDateValueMapper.java

@@ -31,6 +31,10 @@ public class ESDateValueMapper extends AbstractValueMapper<java.util.Date> {
             return new java.util.Date(date.getTime());
         }
 
+        if (val instanceof Long) {
+            return new java.util.Date((Long) val);
+        }
+
         throw new ElasticsearchException(String.format("%s can not find type [%s], val [%s]", getClass().getSimpleName(), val.getClass(), val));
     }
 }