in spark-load/spark-load-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/DppUtils.java [46:73]
public static Class getClassFromDataType(DataType dataType) {
if (dataType == null) {
return null;
}
if (dataType.equals(DataTypes.BooleanType)) {
return Boolean.class;
} else if (dataType.equals(DataTypes.ShortType)) {
return Short.class;
} else if (dataType.equals(DataTypes.IntegerType)) {
return Integer.class;
} else if (dataType.equals(DataTypes.LongType)) {
return Long.class;
} else if (dataType.equals(DataTypes.FloatType)) {
return Float.class;
} else if (dataType.equals(DataTypes.DoubleType)) {
return Double.class;
} else if (dataType.equals(DataTypes.DateType)) {
return Date.class;
} else if (dataType.equals(DataTypes.StringType)) {
return String.class;
} else if (dataType instanceof DecimalType) {
DecimalType decimalType = (DecimalType) dataType;
return BigDecimal.valueOf(decimalType.precision(), decimalType.scale()).getClass();
} else if (dataType.equals(DataTypes.TimestampType)) {
return Long.class;
}
return null;
}