Skip to content

Commit 203f1e1

Browse files
committed
Remove duplicated isEqualFunction in FunctionResolution
1 parent a1a35b2 commit 203f1e1

4 files changed

Lines changed: 5 additions & 11 deletions

File tree

presto-main-base/src/main/java/com/facebook/presto/sql/planner/iterative/properties/EquivalenceClassProperty.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ public EquivalenceClassProperty addPredicate(RowExpression predicate, FunctionRe
196196
private static boolean isVariableEqualVariableOrConstant(FunctionResolution functionResolution, RowExpression expression)
197197
{
198198
if (expression instanceof CallExpression
199-
&& functionResolution.isEqualFunction(((CallExpression) expression).getFunctionHandle())
199+
&& functionResolution.isEqualsFunction(((CallExpression) expression).getFunctionHandle())
200200
&& ((CallExpression) expression).getArguments().size() == 2) {
201201
RowExpression e1 = ((CallExpression) expression).getArguments().get(0);
202202
RowExpression e2 = ((CallExpression) expression).getArguments().get(1);

presto-main-base/src/main/java/com/facebook/presto/sql/planner/iterative/rule/ReorderJoins.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -443,7 +443,7 @@ JoinCondition extractJoinConditions(List<RowExpression> joinPredicates,
443443

444444
for (RowExpression predicate : joinPredicates) {
445445
if (predicate instanceof CallExpression
446-
&& functionResolution.isEqualFunction(((CallExpression) predicate).getFunctionHandle())
446+
&& functionResolution.isEqualsFunction(((CallExpression) predicate).getFunctionHandle())
447447
&& ((CallExpression) predicate).getArguments().size() == 2) {
448448
RowExpression argument0 = ((CallExpression) predicate).getArguments().get(0);
449449
RowExpression argument1 = ((CallExpression) predicate).getArguments().get(1);

presto-main-base/src/main/java/com/facebook/presto/sql/planner/optimizations/PushdownSubfields.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -686,7 +686,7 @@ else if (((LambdaDefinitionExpression) call.getArguments().get(1)).getBody() ins
686686
if (functionResolution.isArrayContainsFunction(callExpression.getFunctionHandle())) {
687687
return extractSubfieldsFromArray((ConstantExpression) callExpression.getArguments().get(0), mapVariable);
688688
}
689-
else if (functionResolution.isEqualFunction(callExpression.getFunctionHandle())) {
689+
else if (functionResolution.isEqualsFunction(callExpression.getFunctionHandle())) {
690690
ConstantExpression mapKey;
691691
if (callExpression.getArguments().get(0) instanceof ConstantExpression) {
692692
mapKey = (ConstantExpression) callExpression.getArguments().get(0);
@@ -1091,7 +1091,7 @@ else if (lambdaDefinitionExpression.getBody() instanceof CallExpression) {
10911091
return callExpression.getArguments().get(0) instanceof ConstantExpression && callExpression.getArguments().get(1) instanceof VariableReferenceExpression
10921092
&& ((VariableReferenceExpression) callExpression.getArguments().get(1)).getName().equals(lambdaDefinitionExpression.getArguments().get(0));
10931093
}
1094-
else if (functionResolution.isEqualFunction(callExpression.getFunctionHandle())) {
1094+
else if (functionResolution.isEqualsFunction(callExpression.getFunctionHandle())) {
10951095
return (callExpression.getArguments().get(0) instanceof VariableReferenceExpression
10961096
&& ((VariableReferenceExpression) callExpression.getArguments().get(0)).getName().equals(lambdaDefinitionExpression.getArguments().get(0))
10971097
&& callExpression.getArguments().get(1) instanceof ConstantExpression)

presto-main-base/src/main/java/com/facebook/presto/sql/relational/FunctionResolution.java

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -275,8 +275,7 @@ public boolean isComparisonFunction(FunctionHandle functionHandle)
275275

276276
public boolean isEqualsFunction(FunctionHandle functionHandle)
277277
{
278-
Optional<OperatorType> operatorType = functionAndTypeResolver.getFunctionMetadata(functionHandle).getOperatorType();
279-
return operatorType.isPresent() && operatorType.get().getOperator().equals(EQUAL.getOperator());
278+
return functionAndTypeResolver.getFunctionMetadata(functionHandle).getOperatorType().map(EQUAL::equals).orElse(false);
280279
}
281280

282281
@Override
@@ -406,11 +405,6 @@ public FunctionHandle approximateSetFunction(Type valueType)
406405
return functionAndTypeResolver.lookupFunction("approx_set", fromTypes(valueType));
407406
}
408407

409-
public boolean isEqualFunction(FunctionHandle functionHandle)
410-
{
411-
return functionAndTypeResolver.getFunctionMetadata(functionHandle).getOperatorType().map(EQUAL::equals).orElse(false);
412-
}
413-
414408
public boolean isArrayContainsFunction(FunctionHandle functionHandle)
415409
{
416410
return functionAndTypeResolver.getFunctionMetadata(functionHandle).getName().equals(functionAndTypeResolver.qualifyObjectName(QualifiedName.of("contains")));

0 commit comments

Comments
 (0)