Skip to content

Commit daab545

Browse files
refactor: getMappedValue function
1 parent a796a13 commit daab545

File tree

1 file changed

+13
-2
lines changed

1 file changed

+13
-2
lines changed

src/main/java/com/influxdb/v3/client/internal/VectorSchemaRootConverter.java

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -118,11 +118,22 @@ public Object getMappedValue(@Nonnull final Field field, @Nullable final Object
118118
return null;
119119
}
120120

121-
var metaType = field.getMetadata().get("iox::column::type");
122121
var fieldName = field.getName();
122+
if ("measurement".equals(fieldName) || "iox::measurement".equals(fieldName)) {
123+
return value.toString();
124+
}
125+
126+
var metaType = field.getMetadata().get("iox::column::type");
127+
if (metaType == null) {
128+
if ("time".equals(fieldName) && (value instanceof Long || value instanceof LocalDateTime)) {
129+
return NanosecondConverter.getTimestampNano(value, field);
130+
} else {
131+
return value;
132+
}
133+
}
134+
123135
String[] parts = metaType.split("::");
124136
String valueType = parts[2];
125-
126137
if ("field".equals(valueType)) {
127138
switch (metaType) {
128139
case "iox::column_type::field::integer":

0 commit comments

Comments
 (0)