From 09888284edea90f5ebcd33e62fe14634758ce653 Mon Sep 17 00:00:00 2001 From: cactuer <52022187+cactuer@users.noreply.github.com> Date: Sat, 18 Jan 2025 17:31:38 +0800 Subject: [PATCH] Update FluxResultMapper.java Add conversion for Instant type properties --- .../java/com/influxdb/query/internal/FluxResultMapper.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/client-core/src/main/java/com/influxdb/query/internal/FluxResultMapper.java b/client-core/src/main/java/com/influxdb/query/internal/FluxResultMapper.java index d2544a22697..041ea98435c 100644 --- a/client-core/src/main/java/com/influxdb/query/internal/FluxResultMapper.java +++ b/client-core/src/main/java/com/influxdb/query/internal/FluxResultMapper.java @@ -22,6 +22,7 @@ package com.influxdb.query.internal; import java.lang.reflect.Field; +import java.time.Instant; import java.math.BigDecimal; import java.util.Map; import java.util.Objects; @@ -157,6 +158,10 @@ private void setFieldValue(@Nonnull final Object object, field.set(object, toBigDecimalValue(value)); return; } + if (Instant.class.isAssignableFrom(fieldType)) { + field.set(object, Instant.parse(value.toString())); + return; + } //enum if (fieldType.isEnum()) {