diff --git a/be/src/exprs/decimalv2_operators.cpp b/be/src/exprs/decimalv2_operators.cpp index 0a5732123b..ef83616566 100644 --- a/be/src/exprs/decimalv2_operators.cpp +++ b/be/src/exprs/decimalv2_operators.cpp @@ -147,6 +147,24 @@ DateTimeVal DecimalV2Operators::cast_to_datetime_val( return result; } +DateTimeVal DecimalV2Operators::cast_to_date_val( + FunctionContext* context, const DecimalV2Val& val) { + if (val.is_null) { + return DateTimeVal::null(); + } + + // convert from DecimalV2Val to DecimalV2Value for caculation + const DecimalV2Value& dv = DecimalV2Value::from_decimal_val(val); + DateTimeValue dt; + if (!dt.from_date_int64(dv)) { + return DateTimeVal::null(); + } + dt.cast_to_date(); + DateTimeVal result; + dt.to_datetime_val(&result); + return result; +} + DecimalVal DecimalV2Operators::cast_to_decimal_val( FunctionContext* context, const DecimalV2Val& val) { if (val.is_null) return DecimalVal::null(); diff --git a/be/src/exprs/decimalv2_operators.h b/be/src/exprs/decimalv2_operators.h index 8030985d46..06d8feed32 100644 --- a/be/src/exprs/decimalv2_operators.h +++ b/be/src/exprs/decimalv2_operators.h @@ -54,6 +54,7 @@ public: static DoubleVal cast_to_double_val(FunctionContext*, const DecimalV2Val&); static StringVal cast_to_string_val(FunctionContext*, const DecimalV2Val&); static DateTimeVal cast_to_datetime_val(FunctionContext*, const DecimalV2Val&); + static DateTimeVal cast_to_date_val(FunctionContext*, const DecimalV2Val&); static DecimalVal cast_to_decimal_val(FunctionContext*, const DecimalV2Val&); static DecimalV2Val add_decimalv2_val_decimalv2_val(