Skip to content

Commit 1118305

Browse files
committed
Remove Decode
1 parent 1530432 commit 1118305

File tree

9 files changed

+2
-381
lines changed

9 files changed

+2
-381
lines changed

datafusion/expr/src/built_in_function.rs

Lines changed: 0 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -72,8 +72,6 @@ pub enum BuiltinScalarFunction {
7272
Cos,
7373
/// cos
7474
Cosh,
75-
/// Decode
76-
Decode,
7775
/// degrees
7876
Degrees,
7977
/// Digest
@@ -351,7 +349,6 @@ impl BuiltinScalarFunction {
351349
BuiltinScalarFunction::Coalesce => Volatility::Immutable,
352350
BuiltinScalarFunction::Cos => Volatility::Immutable,
353351
BuiltinScalarFunction::Cosh => Volatility::Immutable,
354-
BuiltinScalarFunction::Decode => Volatility::Immutable,
355352
BuiltinScalarFunction::Degrees => Volatility::Immutable,
356353
BuiltinScalarFunction::Exp => Volatility::Immutable,
357354
BuiltinScalarFunction::Factorial => Volatility::Immutable,
@@ -707,18 +704,6 @@ impl BuiltinScalarFunction {
707704
BuiltinScalarFunction::Digest => {
708705
utf8_or_binary_to_binary_type(&input_expr_types[0], "digest")
709706
}
710-
BuiltinScalarFunction::Decode => Ok(match input_expr_types[0] {
711-
Utf8 => Binary,
712-
LargeUtf8 => LargeBinary,
713-
Binary => Binary,
714-
LargeBinary => LargeBinary,
715-
Null => Null,
716-
_ => {
717-
return plan_err!(
718-
"The decode function can only accept utf8 or binary."
719-
);
720-
}
721-
}),
722707
BuiltinScalarFunction::SplitPart => {
723708
utf8_to_str_type(&input_expr_types[0], "split_part")
724709
}
@@ -1023,15 +1008,6 @@ impl BuiltinScalarFunction {
10231008
],
10241009
self.volatility(),
10251010
),
1026-
BuiltinScalarFunction::Decode => Signature::one_of(
1027-
vec![
1028-
Exact(vec![Utf8, Utf8]),
1029-
Exact(vec![LargeUtf8, Utf8]),
1030-
Exact(vec![Binary, Utf8]),
1031-
Exact(vec![LargeBinary, Utf8]),
1032-
],
1033-
self.volatility(),
1034-
),
10351011
BuiltinScalarFunction::DateTrunc => Signature::one_of(
10361012
vec![
10371013
Exact(vec![Utf8, Timestamp(Nanosecond, None)]),
@@ -1437,9 +1413,6 @@ fn aliases(func: &BuiltinScalarFunction) -> &'static [&'static str] {
14371413
BuiltinScalarFunction::SHA384 => &["sha384"],
14381414
BuiltinScalarFunction::SHA512 => &["sha512"],
14391415

1440-
// encode/decode
1441-
BuiltinScalarFunction::Decode => &["decode"],
1442-
14431416
// other functions
14441417
BuiltinScalarFunction::ArrowTypeof => &["arrow_typeof"],
14451418

datafusion/functions/src/encoding/mod.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,8 @@ use std::sync::{Arc, OnceLock};
2828
use DataType::*;
2929

3030
// TODO make stub implementations when feature is not activated
31+
//#[cfg(feature = "encoding_expressions")]
32+
//pub mod encoding_expressions;
3133

3234
pub fn encode_udf() -> ScalarUDF {
3335
ScalarUDF::new_from_impl(Arc::new(EncodeFunc {}))

0 commit comments

Comments
 (0)