Skip to content

Commit f65d995

Browse files
committed
fix
1 parent b06a8ce commit f65d995

File tree

3 files changed

+7
-44
lines changed

3 files changed

+7
-44
lines changed

datafusion/expr/src/built_in_function.rs

-14
Original file line numberDiff line numberDiff line change
@@ -726,15 +726,6 @@ impl BuiltinScalarFunction {
726726
BuiltinScalarFunction::FromUnixtime => {
727727
Signature::uniform(1, vec![Int64], self.volatility())
728728
}
729-
BuiltinScalarFunction::Digest => Signature::one_of(
730-
vec![
731-
Exact(vec![Utf8, Utf8]),
732-
Exact(vec![LargeUtf8, Utf8]),
733-
Exact(vec![Binary, Utf8]),
734-
Exact(vec![LargeBinary, Utf8]),
735-
],
736-
self.volatility(),
737-
),
738729
BuiltinScalarFunction::SplitPart => Signature::one_of(
739730
vec![
740731
Exact(vec![Utf8, Utf8, Int64]),
@@ -1006,11 +997,6 @@ impl BuiltinScalarFunction {
1006997
BuiltinScalarFunction::FromUnixtime => &["from_unixtime"],
1007998

1008999
// hashing functions
1009-
BuiltinScalarFunction::MD5 => &["md5"],
1010-
BuiltinScalarFunction::SHA224 => &["sha224"],
1011-
BuiltinScalarFunction::SHA256 => &["sha256"],
1012-
BuiltinScalarFunction::SHA384 => &["sha384"],
1013-
BuiltinScalarFunction::SHA512 => &["sha512"],
10141000
BuiltinScalarFunction::ArrayElement => &[
10151001
"array_element",
10161002
"array_extract",

datafusion/proto/src/logical_plan/from_proto.rs

+7-25
Original file line numberDiff line numberDiff line change
@@ -52,17 +52,17 @@ use datafusion_expr::{
5252
array_repeat, array_replace, array_replace_all, array_replace_n, array_resize,
5353
array_slice, array_union, ascii, asinh, atan, atan2, atanh, bit_length, btrim, cbrt,
5454
ceil, character_length, chr, coalesce, concat_expr, concat_ws_expr, cos, cosh, cot,
55-
current_date, current_time, degrees, digest, ends_with, exp,
55+
current_date, current_time, degrees, ends_with, exp,
5656
expr::{self, InList, Sort, WindowFunction},
5757
factorial, find_in_set, floor, from_unixtime, gcd, initcap, iszero, lcm, left,
5858
levenshtein, ln, log, log10, log2,
5959
logical_plan::{PlanType, StringifiedPlan},
60-
lower, lpad, ltrim, md5, nanvl, now, octet_length, overlay, pi, power, radians,
61-
random, repeat, replace, reverse, right, round, rpad, rtrim, sha224, sha256, sha384,
62-
sha512, signum, sin, sinh, split_part, sqrt, starts_with, strpos, substr,
63-
substr_index, substring, to_hex, translate, trim, trunc, upper, uuid,
64-
AggregateFunction, Between, BinaryExpr, BuiltInWindowFunction, BuiltinScalarFunction,
65-
Case, Cast, Expr, GetFieldAccess, GetIndexedField, GroupingSet,
60+
lower, lpad, ltrim, nanvl, now, octet_length, overlay, pi, power, radians, random,
61+
repeat, replace, reverse, right, round, rpad, rtrim, signum, sin, sinh, split_part,
62+
sqrt, starts_with, strpos, substr, substr_index, substring, to_hex, translate, trim,
63+
trunc, upper, uuid, AggregateFunction, Between, BinaryExpr, BuiltInWindowFunction,
64+
BuiltinScalarFunction, Case, Cast, Expr, GetFieldAccess, GetIndexedField,
65+
GroupingSet,
6666
GroupingSet::GroupingSets,
6767
JoinConstraint, JoinType, Like, Operator, TryCast, WindowFrame, WindowFrameBound,
6868
WindowFrameUnits,
@@ -490,11 +490,6 @@ impl From<&protobuf::ScalarFunction> for BuiltinScalarFunction {
490490
ScalarFunction::ArrayIntersect => Self::ArrayIntersect,
491491
ScalarFunction::ArrayUnion => Self::ArrayUnion,
492492
ScalarFunction::ArrayResize => Self::ArrayResize,
493-
ScalarFunction::Md5 => Self::MD5,
494-
ScalarFunction::Sha224 => Self::SHA224,
495-
ScalarFunction::Sha256 => Self::SHA256,
496-
ScalarFunction::Sha384 => Self::SHA384,
497-
ScalarFunction::Sha512 => Self::SHA512,
498493
ScalarFunction::Log2 => Self::Log2,
499494
ScalarFunction::Signum => Self::Signum,
500495
ScalarFunction::Ascii => Self::Ascii,
@@ -1532,19 +1527,6 @@ pub fn parse_expr(
15321527
ScalarFunction::Rtrim => {
15331528
Ok(rtrim(parse_expr(&args[0], registry, codec)?))
15341529
}
1535-
ScalarFunction::Sha224 => {
1536-
Ok(sha224(parse_expr(&args[0], registry, codec)?))
1537-
}
1538-
ScalarFunction::Sha256 => {
1539-
Ok(sha256(parse_expr(&args[0], registry, codec)?))
1540-
}
1541-
ScalarFunction::Sha384 => {
1542-
Ok(sha384(parse_expr(&args[0], registry, codec)?))
1543-
}
1544-
ScalarFunction::Sha512 => {
1545-
Ok(sha512(parse_expr(&args[0], registry, codec)?))
1546-
}
1547-
ScalarFunction::Md5 => Ok(md5(parse_expr(&args[0], registry, codec)?)),
15481530
ScalarFunction::Ascii => {
15491531
Ok(ascii(parse_expr(&args[0], registry, codec)?))
15501532
}

datafusion/proto/src/logical_plan/to_proto.rs

-5
Original file line numberDiff line numberDiff line change
@@ -1472,11 +1472,6 @@ impl TryFrom<&BuiltinScalarFunction> for protobuf::ScalarFunction {
14721472
BuiltinScalarFunction::ArraySlice => Self::ArraySlice,
14731473
BuiltinScalarFunction::ArrayIntersect => Self::ArrayIntersect,
14741474
BuiltinScalarFunction::ArrayUnion => Self::ArrayUnion,
1475-
BuiltinScalarFunction::MD5 => Self::Md5,
1476-
BuiltinScalarFunction::SHA224 => Self::Sha224,
1477-
BuiltinScalarFunction::SHA256 => Self::Sha256,
1478-
BuiltinScalarFunction::SHA384 => Self::Sha384,
1479-
BuiltinScalarFunction::SHA512 => Self::Sha512,
14801475
BuiltinScalarFunction::Log2 => Self::Log2,
14811476
BuiltinScalarFunction::Signum => Self::Signum,
14821477
BuiltinScalarFunction::Ascii => Self::Ascii,

0 commit comments

Comments
 (0)