From 7211f8b2c0c86f69066c8a9f15f3ccdcef57dbe9 Mon Sep 17 00:00:00 2001 From: Alexey Kudinkin Date: Tue, 23 Nov 2021 10:17:54 -0800 Subject: [PATCH] Fixed compilation --- .../scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala index 34f529f95739..90980395aebf 100644 --- a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala +++ b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala @@ -122,7 +122,7 @@ object DataSkippingUtils { // Translates to "colA_maxValue >= b" for index lookup case GreaterThanOrEqual(attribute: AttributeReference, right: Literal) => val colName = getTargetColNameParts(attribute) - reWriteCondition(colName, GreaterThanOrEqual(maxValue(colName), right)) + rewriteCondition(colName, GreaterThanOrEqual(maxValue(colName), right)) // Filter "b >= colA" // Translates to "b >= colA_minValue" for index lookup case GreaterThanOrEqual(value: Literal, attribute: AttributeReference) =>