Skip to content

Commit

Permalink
change msqNotCompatible -> msqIncompatible
Browse files Browse the repository at this point in the history
  • Loading branch information
LakshSingla committed Sep 7, 2023
1 parent d2d8620 commit 18a6c7c
Show file tree
Hide file tree
Showing 3 changed files with 111 additions and 111 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1171,7 +1171,7 @@ protected void skipVectorize()
skipVectorize = true;
}

protected void notMsqCompatible()
protected void msqIncompatible()
{
msqCompatible = false;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -695,7 +695,7 @@ public void testFilterAndGroupByLookupUsingJoinOperatorBackwards(Map<String, Obj
// Like "testFilterAndGroupByLookupUsingJoinOperator", but with the table and lookup reversed.

// MSQ refuses to do RIGHT join with broadcast.
notMsqCompatible();
msqIncompatible();

// Cannot vectorize JOIN operator.
cannotVectorize();
Expand Down Expand Up @@ -784,7 +784,7 @@ public void testFilterAndGroupByLookupUsingJoinOperatorWithNotFilter(Map<String,
public void testJoinUnionTablesOnLookup(Map<String, Object> queryContext)
{
// MSQ does not support UNION ALL.
notMsqCompatible();
msqIncompatible();
// Cannot vectorize JOIN operator.
cannotVectorize();

Expand Down Expand Up @@ -1918,7 +1918,7 @@ public void testCommaJoinTableLookupTableMismatchedTypes(Map<String, Object> que
// Regression test for https://github.com/apache/druid/issues/9646.

// Empty-dataset aggregation queries in MSQ return an empty row, rather than a single row as SQL requires.
notMsqCompatible();
msqIncompatible();

// Cannot vectorize JOIN operator.
cannotVectorize();
Expand Down Expand Up @@ -1974,7 +1974,7 @@ public void testCommaJoinTableLookupTableMismatchedTypes(Map<String, Object> que
public void testJoinTableLookupTableMismatchedTypesWithoutComma(Map<String, Object> queryContext)
{
// Empty-dataset aggregation queries in MSQ return an empty row, rather than a single row as SQL requires.
notMsqCompatible();
msqIncompatible();

// Cannot vectorize JOIN operator.
cannotVectorize();
Expand Down Expand Up @@ -2396,7 +2396,7 @@ public void testSelectOnLookupUsingLeftJoinOperator(Map<String, Object> queryCon
public void testSelectOnLookupUsingRightJoinOperator(Map<String, Object> queryContext)
{
// MSQ refuses to do RIGHT join with broadcast.
notMsqCompatible();
msqIncompatible();

testQuery(
"SELECT dim1, lookyloo.*\n"
Expand Down Expand Up @@ -2438,7 +2438,7 @@ public void testSelectOnLookupUsingRightJoinOperator(Map<String, Object> queryCo
public void testSelectOnLookupUsingFullJoinOperator(Map<String, Object> queryContext)
{
// MSQ refuses to do FULL join with broadcast.
notMsqCompatible();
msqIncompatible();

testQuery(
"SELECT dim1, m1, cnt, lookyloo.*\n"
Expand Down Expand Up @@ -3652,7 +3652,7 @@ public void testInnerJoinSubqueryWithSelectorFilter(Map<String, Object> queryCon
{
if (sortBasedJoin) {
// Cannot handle the [l1.k = 'abc'] condition.
notMsqCompatible();
msqIncompatible();
}

// Cannot vectorize due to 'concat' expression.
Expand Down Expand Up @@ -4073,7 +4073,7 @@ public void testSemiJoinWithOuterTimeExtractAggregateWithOrderBy()
public void testJoinOnMultiValuedColumnShouldThrowException(Map<String, Object> queryContext)
{
// MSQ throws a slightly different error than QueryException.
notMsqCompatible();
msqIncompatible();

final String query = "SELECT dim3, l.v from druid.foo f inner join lookup.lookyloo l on f.dim3 = l.k\n";

Expand All @@ -4090,7 +4090,7 @@ public void testJoinOnMultiValuedColumnShouldThrowException(Map<String, Object>
public void testUnionAllTwoQueriesLeftQueryIsJoin(Map<String, Object> queryContext)
{
// MSQ does not support UNION ALL.
notMsqCompatible();
msqIncompatible();

// Fully removing the join allows this query to vectorize.
if (!isRewriteJoinToFilter(queryContext)) {
Expand Down Expand Up @@ -4134,7 +4134,7 @@ public void testUnionAllTwoQueriesLeftQueryIsJoin(Map<String, Object> queryConte
public void testUnionAllTwoQueriesRightQueryIsJoin(Map<String, Object> queryContext)
{
// MSQ does not support UNION ALL.
notMsqCompatible();
msqIncompatible();

// Fully removing the join allows this query to vectorize.
if (!isRewriteJoinToFilter(queryContext)) {
Expand Down Expand Up @@ -4177,7 +4177,7 @@ public void testUnionAllTwoQueriesRightQueryIsJoin(Map<String, Object> queryCont
public void testUnionAllTwoQueriesBothQueriesAreJoin()
{
// MSQ does not support UNION ALL.
notMsqCompatible();
msqIncompatible();
cannotVectorize();

testQuery(
Expand Down Expand Up @@ -4883,7 +4883,7 @@ public void testVirtualColumnOnMVFilterJoinExpression(Map<String, Object> queryC
// IndexedTableDimensionSelector. In native, this doesn't happen, because we don't have as much type information,
// and we end up using IndexedTableColumnValueSelector instead. This is really a problem with
// IndexedTableColumnSelectorFactory: it assumes strings are not multi-valued, even though they might be.
notMsqCompatible();
msqIncompatible();

testQuery(
"SELECT foo1.dim3, foo2.dim3 FROM druid.numfoo as foo1 INNER JOIN druid.numfoo as foo2 "
Expand Down Expand Up @@ -4939,7 +4939,7 @@ public void testVirtualColumnOnMVFilterMultiJoinExpression(Map<String, Object> q
// IndexedTableDimensionSelector. In native, this doesn't happen, because we don't have as much type information,
// and we end up using IndexedTableColumnValueSelector instead. This is really a problem with
// IndexedTableColumnSelectorFactory: it assumes strings are not multi-valued, even though they might be.
notMsqCompatible();
msqIncompatible();

testQuery(
"SELECT foo1.dim3, foo2.dim3 FROM druid.numfoo as foo1 INNER JOIN "
Expand Down
Loading

0 comments on commit 18a6c7c

Please sign in to comment.