wip

Author: NguyenHoangSon96

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

@@ -221,7 +221,7 @@ public Stream<Object[]> query(@Nonnull final String query,
                                             } else if ("timestamp".equals(valueType)
                                                     || Objects.equals(schema.getName(), "time")) {
                                                 var timestamp = fieldVectors.get(i).getObject(rowNumber);
-                                                BigInteger time = NanosecondConverter.getTimestampNanoSecond(timestamp, schema);
+                                                BigInteger time = NanosecondConverter.getTimestampNano(timestamp, schema);
                                                 row.add(time);
                                             } else {
                                                 Object value = fieldVectors.get(i).getObject(rowNumber);

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

@@ -119,7 +119,7 @@ public static BigInteger convert(final Instant instant, final WritePrecision pre
         return FROM_NANOS.get(precision).apply(nanos);
     }
 
-    public static BigInteger getTimestampNanoSecond(@Nonnull final Object value, @Nonnull final Field schema) {
+    public static BigInteger getTimestampNano(@Nonnull final Object value, @Nonnull final Field schema) {
         BigInteger result = null;
 
         if (value instanceof Long) {

src/test/java/com/influxdb/v3/client/internal/NanosecondConverterTest.java

@@ -20,7 +20,7 @@ void testGetTimestampNanosecond() {
                                                  new ArrowType.Timestamp(TimeUnit.SECOND, "UTC"),
                                                  null);
         Field timeFieldSecond = new Field("time", timeTypeSecond, null);
-        timestampNanoSecond = NanosecondConverter.getTimestampNanoSecond(123_456L, timeFieldSecond);
+        timestampNanoSecond = NanosecondConverter.getTimestampNano(123_456L, timeFieldSecond);
         Assertions.assertEquals(
                 BigInteger.valueOf(123_456L)
                           .multiply(BigInteger.valueOf(1_000_000_000)), timestampNanoSecond
@@ -31,7 +31,7 @@ void testGetTimestampNanosecond() {
                                                       new ArrowType.Timestamp(TimeUnit.MILLISECOND, "UTC"),
                                                       null);
         Field timeFieldMilliSecond = new Field("time", timeTypeMilliSecond, null);
-        timestampNanoSecond = NanosecondConverter.getTimestampNanoSecond(123_456L, timeFieldMilliSecond);
+        timestampNanoSecond = NanosecondConverter.getTimestampNano(123_456L, timeFieldMilliSecond);
         Assertions.assertEquals(
                 BigInteger.valueOf(123_456L)
                           .multiply(BigInteger.valueOf(1_000_000)), timestampNanoSecond
@@ -42,7 +42,7 @@ void testGetTimestampNanosecond() {
                                                       new ArrowType.Timestamp(TimeUnit.MICROSECOND, "UTC"),
                                                       null);
         Field timeFieldMicroSecond = new Field("time", timeTypeMicroSecond, null);
-        timestampNanoSecond = NanosecondConverter.getTimestampNanoSecond(123_456L, timeFieldMicroSecond);
+        timestampNanoSecond = NanosecondConverter.getTimestampNano(123_456L, timeFieldMicroSecond);
         Assertions.assertEquals(
                 BigInteger.valueOf(123_456L)
                           .multiply(BigInteger.valueOf(1_000)), timestampNanoSecond
@@ -53,7 +53,7 @@ void testGetTimestampNanosecond() {
                                                       new ArrowType.Timestamp(TimeUnit.NANOSECOND, "UTC"),
                                                       null);
         Field timeFieldNanoSecond = new Field("time", timeTypeNanoSecond, null);
-        timestampNanoSecond = NanosecondConverter.getTimestampNanoSecond(123_456L, timeFieldNanoSecond);
+        timestampNanoSecond = NanosecondConverter.getTimestampNano(123_456L, timeFieldNanoSecond);
         Assertions.assertEquals(BigInteger.valueOf(123_456L), timestampNanoSecond
         );
     }