Skip to content

Commit 3a85dea

Browse files
wip
1 parent 52d294b commit 3a85dea

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,8 @@ public Stream<Object[]> query(@Nonnull final String query,
218218
break;
219219
default:
220220
}
221-
} else if ("timestamp".equals(valueType) || Objects.equals(schema.getName(), "time")) {
221+
} else if ("timestamp".equals(valueType)
222+
|| Objects.equals(schema.getName(), "time")) {
222223
var timestamp = fieldVectors.get(i).getObject(rowNumber);
223224
BigInteger time = NanosecondConverter.getTimestamp(timestamp, schema);
224225
row.add(time);

0 commit comments

Comments
 (0)