in fluss-common/src/main/java/com/alibaba/fluss/row/InternalRow.java [154:188]
static Class<?> getDataClass(DataType type) {
// ordered by type root definition
switch (type.getTypeRoot()) {
case CHAR:
case STRING:
return BinaryString.class;
case BOOLEAN:
return Boolean.class;
case BINARY:
case BYTES:
return byte[].class;
case DECIMAL:
return Decimal.class;
case TINYINT:
return Byte.class;
case SMALLINT:
return Short.class;
case INTEGER:
case DATE:
case TIME_WITHOUT_TIME_ZONE:
return Integer.class;
case BIGINT:
return Long.class;
case FLOAT:
return Float.class;
case DOUBLE:
return Double.class;
case TIMESTAMP_WITHOUT_TIME_ZONE:
return TimestampNtz.class;
case TIMESTAMP_WITH_LOCAL_TIME_ZONE:
return TimestampLtz.class;
default:
throw new IllegalArgumentException("Illegal type: " + type);
}
}