Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -38,9 +38,7 @@
import static io.trino.metadata.OperatorNameUtil.mangleOperatorName;
import static io.trino.operator.scalar.timestamp.VarcharToTimestampCast.castToLongTimestamp;
import static io.trino.spi.StandardErrorCode.INVALID_FUNCTION_ARGUMENT;
import static io.trino.spi.StandardErrorCode.NOT_SUPPORTED;
import static io.trino.spi.type.DecimalType.createDecimalType;
import static io.trino.testing.assertions.TrinoExceptionAssert.assertTrinoExceptionThrownBy;
import static java.lang.String.format;
import static java.util.Objects.requireNonNull;
import static org.testng.Assert.fail;
Expand Down Expand Up @@ -151,13 +149,6 @@ protected void assertCachedInstanceHasBoundedRetainedSize(String projection)
functionAssertions.assertCachedInstanceHasBoundedRetainedSize(projection);
}

protected void assertNotSupported(String projection, String message)
{
assertTrinoExceptionThrownBy(() -> functionAssertions.executeProjectionWithFullEngine(projection))
.hasErrorCode(NOT_SUPPORTED)
.hasMessage(message);
}

protected void tryEvaluateWithAll(String projection, Type expectedType)
{
functionAssertions.tryEvaluateWithAll(projection, expectedType);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -220,11 +220,6 @@ public final class FunctionAssertions
private final LocalQueryRunner runner;
private final TestingFunctionResolution testingFunctionResolution;

public FunctionAssertions()
{
this(TEST_SESSION);
}

public FunctionAssertions(Session session)
{
this(session, new FeaturesConfig());
Expand Down Expand Up @@ -635,11 +630,6 @@ private Object selectSingleValue(Operator operator, Type type)
return type.getObjectValue(session.toConnectorSession(), block, 0);
}

public void assertFilter(String filter, boolean expected, boolean withNoInputColumns)
{
assertFilter(filter, expected, withNoInputColumns, runner.getExpressionCompiler());
}

private void assertFilter(String filter, boolean expected, boolean withNoInputColumns, ExpressionCompiler compiler)
{
List<Boolean> results = executeFilterWithAll(filter, TEST_SESSION, withNoInputColumns, compiler);
Expand Down

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,9 @@
import io.trino.sql.analyzer.ExpressionAnalyzer;
import io.trino.sql.analyzer.Scope;
import io.trino.sql.parser.SqlParser;
import io.trino.sql.planner.DesugarArrayConstructorRewriter;
import io.trino.sql.planner.DesugarLikeRewriter;
import io.trino.sql.planner.TypeProvider;
import io.trino.sql.planner.assertions.ExpressionVerifier;
import io.trino.sql.planner.assertions.SymbolAliases;
import io.trino.sql.planner.iterative.rule.CanonicalizeExpressionRewriter;
import io.trino.sql.tree.Cast;
import io.trino.sql.tree.Expression;
import io.trino.sql.tree.ExpressionRewriter;
Expand Down Expand Up @@ -104,11 +101,7 @@ public static Expression planExpression(PlannerContext plannerContext, Session s

private static Expression planExpressionInExistingTx(PlannerContext plannerContext, TypeProvider typeProvider, Expression expression, Session transactionSession)
{
Expression rewritten = rewriteIdentifiersToSymbolReferences(expression);
rewritten = DesugarLikeRewriter.rewrite(rewritten, transactionSession, plannerContext.getMetadata(), createTestingTypeAnalyzer(plannerContext), typeProvider);
rewritten = DesugarArrayConstructorRewriter.rewrite(rewritten, transactionSession, plannerContext.getMetadata(), createTestingTypeAnalyzer(plannerContext), typeProvider);
rewritten = CanonicalizeExpressionRewriter.rewrite(rewritten, transactionSession, plannerContext, createTestingTypeAnalyzer(plannerContext), typeProvider);
return resolveFunctionCalls(plannerContext, transactionSession, typeProvider, rewritten);
return resolveFunctionCalls(plannerContext, transactionSession, typeProvider, rewriteIdentifiersToSymbolReferences(expression));
}

public static Expression resolveFunctionCalls(PlannerContext plannerContext, Session session, TypeProvider typeProvider, Expression expression)
Expand Down
Loading