Remove time property when storing event in data lake
@@ -176,6 +176,10 @@ public class DataLakeInfluxDbClient {
for (EventProperty ep : schema.getEventProperties()) {
if (ep instanceof EventPropertyPrimitive) {
String runtimeName = ep.getRuntimeName();
+
+
+
+ if (!runtimeName.equals(timestampField.split("::")[1])) {
String preparedRuntimeName = DataLake.prepareString(runtimeName);
PrimitiveField eventPropertyPrimitiveField = event.getFieldByRuntimeName(runtimeName).getAsPrimitive();
@@ -201,6 +205,7 @@ public class DataLakeInfluxDbClient {
}
}
}
+ }
influxDb.write(p.build());
}
