in performancetest/src/main/java/software/amazon/timestream/performancetest/TimestreamSDK.java [107:150]
private static Object parseScalarType(final ColumnInfo info, final Datum datum) {
switch (ScalarType.fromValue(info.getType().getScalarType())) {
case INTERVAL_DAY_TO_SECOND:
case INTERVAL_YEAR_TO_MONTH:
case UNKNOWN:
case VARCHAR: {
return datum.getScalarValue();
}
case BIGINT: {
return Long.parseLong(datum.getScalarValue());
}
case INTEGER: {
return Integer.parseInt(datum.getScalarValue());
}
case BOOLEAN: {
return Boolean.parseBoolean(datum.getScalarValue());
}
case DOUBLE: {
return Double.parseDouble(datum.getScalarValue());
}
case TIMESTAMP: {
return Timestamp
.valueOf(LocalDateTime.parse(datum.getScalarValue(), TIMESTAMP_FORMATTER));
}
case DATE: {
return Date.valueOf(LocalDate.parse(datum.getScalarValue(), DATE_FORMATTER));
}
case TIME: {
return Time.valueOf(LocalTime.parse(datum.getScalarValue(), TIME_FORMATTER));
}
default: {
throw new IllegalArgumentException(
"Given type is not valid: " + info.getType().getScalarType());
}
}
}