Skip to content

Commit 6b4d2ef

Browse files
committed
update more
1 parent becf0f8 commit 6b4d2ef

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

src/materialized/dependencies.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -222,7 +222,7 @@ impl TableFunctionImpl for StaleFilesUdtf {
222222
/// Extract table name from args passed to TableFunctionImpl::call()
223223
fn get_table_name(args: &[Expr]) -> Result<&String> {
224224
match &args[0] {
225-
Expr::Literal(ScalarValue::Utf8(Some(table_name))) => Ok(table_name),
225+
Expr::Literal(ScalarValue::Utf8(Some(table_name)), _) => Ok(table_name),
226226
_ => Err(DataFusionError::Plan(
227227
"expected a single string literal argument to mv_dependencies".to_string(),
228228
)),

src/rewrite/normal_form.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -597,15 +597,15 @@ impl Predicate {
597597
/// Add a binary expression to our collection of filters.
598598
fn insert_binary_expr(&mut self, left: &Expr, op: Operator, right: &Expr) -> Result<()> {
599599
match (left, op, right) {
600-
(Expr::Column(c), op, Expr::Literal(v)) => {
600+
(Expr::Column(c), op, Expr::Literal(v, _)) => {
601601
if let Err(e) = self.add_range(c, &op, v) {
602602
// Add a range can fail in some cases, so just fallthrough
603603
log::debug!("failed to add range filter: {e}");
604604
} else {
605605
return Ok(());
606606
}
607607
}
608-
(Expr::Literal(_), op, Expr::Column(_)) => {
608+
(Expr::Literal(_, _), op, Expr::Column(_)) => {
609609
if let Some(swapped) = op.swap() {
610610
return self.insert_binary_expr(right, swapped, left);
611611
}
@@ -718,22 +718,22 @@ impl Predicate {
718718
extra_range_filters.push(Expr::BinaryExpr(BinaryExpr {
719719
left: Box::new(Expr::Column(other_column.clone())),
720720
op: Operator::Eq,
721-
right: Box::new(Expr::Literal(range.lower().clone())),
721+
right: Box::new(Expr::Literal(range.lower().clone(), None)),
722722
}))
723723
} else {
724724
if !range.lower().is_null() {
725725
extra_range_filters.push(Expr::BinaryExpr(BinaryExpr {
726726
left: Box::new(Expr::Column(other_column.clone())),
727727
op: Operator::GtEq,
728-
right: Box::new(Expr::Literal(range.lower().clone())),
728+
right: Box::new(Expr::Literal(range.lower().clone(), None)),
729729
}))
730730
}
731731

732732
if !range.upper().is_null() {
733733
extra_range_filters.push(Expr::BinaryExpr(BinaryExpr {
734734
left: Box::new(Expr::Column(other_column.clone())),
735735
op: Operator::LtEq,
736-
right: Box::new(Expr::Literal(range.upper().clone())),
736+
right: Box::new(Expr::Literal(range.upper().clone(), None)),
737737
}))
738738
}
739739
}

0 commit comments

Comments
 (0)