org.apache.drill.exec.physical.impl.lateraljoin

Class TestLateralPlans

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.ExecTest

org.apache.drill.test.BaseTestQuery

org.apache.drill.exec.physical.impl.lateraljoin.TestLateralPlans

public class TestLateralPlans
extends BaseTestQuery

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.test.BaseTestQuery

BaseTestQuery.ClassicTestServices, BaseTestQuery.SilentListener, BaseTestQuery.TestResultSet

Nested classes/interfaces inherited from class org.apache.drill.test.DrillTest

DrillTest.MemWatcher

Field Summary

Fields inherited from class org.apache.drill.test.BaseTestQuery

allocator, bits, client, config, serviceSet

Fields inherited from class org.apache.drill.exec.ExecTest

c, dirTestWatcher, optionManager

Fields inherited from class org.apache.drill.test.DrillTest

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestLateralPlans()

Method Summary

Modifier and Type	Method and Description
static void	enableUnnestLateral()
void	testExplainLateralSql()
void	testFilterPushCorrelate()
void	testLateralAndUnnestExplainPlan()
void	testLateralSql()
void	testLateralSqlPlainCol()
void	testLateralSqlStar()
void	testLateralSqlStar2()
void	testLateralSqlStar3()
void	testLateralSqlStar4()
void	testLateralSqlWithAS()
void	testMultiUnnestLateralAtSameLevel()
void	testMultiUnnestQuery()
void	testNestedColumnQuery()
void	testNoExchangeWithAggWithoutGrpBy() Following test cases are introduced to make sure no exchanges are present on right side of Lateral join.
void	testNoExchangeWithHashAggWithGrpBy()
void	testNoExchangeWithLateralsDownStreamAgg()
void	testNoExchangeWithLateralsDownStreamJoin()
void	testNoExchangeWithLateralsDownStreamUnion()
void	testNoExchangeWithOrderByLimit()
void	testNoExchangeWithOrderByWithoutLimit()
void	testNoExchangeWithStreamAggWithGrpBy()
void	testSubQuerySql()
void	testUnnestColumnAlias()
void	testUnnestTableAndColumnAlias()
void	testUnnestTopN()
void	testUnnestWithAggInSubquery()
void	testUnnestWithAggOnOuterTable()
void	testUnnestWithFilter()

Methods inherited from class org.apache.drill.test.BaseTestQuery

alterSession, cloneDefaultTestConfigProperties, closeClient, errorMsgTestHelper, getAllocator, getDrillbitContext, getFile, getPhysicalFileFromResource, getResultString, getUserPort, logResult, newTest, parseErrorHelper, printResult, resetAllSessionOptions, resetDrillbitCount, resetSessionOption, runSQL, setColumnWidth, setColumnWidths, setSessionOption, setSessionOption, setSessionOption, setSessionOption, setupDefaultTestCluster, test, test, testBuilder, testLogicalWithResults, testNoResult, testNoResult, testPhysical, testPhysicalFromFile, testPhysicalWithResults, testPreparedStatement, testRunAndPrint, testRunAndReturn, testSql, testSqlWithResults, testWithListener, updateClient, updateClient, updateClient, updateTestCluster, updateTestCluster

Methods inherited from class org.apache.drill.exec.ExecTest

clear, getLocalFileSystem, mockDrillbitContext, mockUsDateFormatSymbols, mockUtcDateTimeZone, parseExpr, setupOptionManager

Methods inherited from class org.apache.drill.test.DrillTest

escapeJsonString, finishDrillTest, initDrillTest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestLateralPlans

public TestLateralPlans()

Method Detail

enableUnnestLateral

public static void enableUnnestLateral()
                                throws Exception

Throws:

Exception

testLateralSql

public void testLateralSql()
                    throws Exception

Throws:

Exception

testExplainLateralSql

public void testExplainLateralSql()
                           throws Exception

Throws:

Exception

testFilterPushCorrelate

public void testFilterPushCorrelate()
                             throws Exception

Throws:

Exception

testLateralSqlPlainCol

public void testLateralSqlPlainCol()
                            throws Exception

Throws:

Exception

testLateralSqlStar

public void testLateralSqlStar()
                        throws Exception

Throws:

Exception

testLateralSqlStar2

public void testLateralSqlStar2()
                         throws Exception

Throws:

Exception

testLateralSqlStar3

public void testLateralSqlStar3()
                         throws Exception

Throws:

Exception

testLateralSqlStar4

public void testLateralSqlStar4()
                         throws Exception

Throws:

Exception

testLateralSqlWithAS

public void testLateralSqlWithAS()
                          throws Exception

Throws:

Exception

testMultiUnnestLateralAtSameLevel

public void testMultiUnnestLateralAtSameLevel()
                                       throws Exception

Throws:

Exception

testSubQuerySql

public void testSubQuerySql()
                     throws Exception

Throws:

Exception

testUnnestWithFilter

public void testUnnestWithFilter()
                          throws Exception

Throws:

Exception

testUnnestWithAggInSubquery

public void testUnnestWithAggInSubquery()
                                 throws Exception

Throws:

Exception

testUnnestWithAggOnOuterTable

public void testUnnestWithAggOnOuterTable()
                                   throws Exception

Throws:

Exception

testUnnestTableAndColumnAlias

public void testUnnestTableAndColumnAlias()
                                   throws Exception

Throws:

Exception

testUnnestColumnAlias

public void testUnnestColumnAlias()
                           throws Exception

Throws:

Exception

testNoExchangeWithAggWithoutGrpBy

public void testNoExchangeWithAggWithoutGrpBy()
                                       throws Exception

Following test cases are introduced to make sure no exchanges are present on right side of Lateral join.

Throws:

Exception

testNoExchangeWithStreamAggWithGrpBy

public void testNoExchangeWithStreamAggWithGrpBy()
                                          throws Exception

Throws:

Exception

testNoExchangeWithHashAggWithGrpBy

public void testNoExchangeWithHashAggWithGrpBy()
                                        throws Exception

Throws:

Exception

testNoExchangeWithOrderByWithoutLimit

public void testNoExchangeWithOrderByWithoutLimit()
                                           throws Exception

Throws:

Exception

testNoExchangeWithOrderByLimit

public void testNoExchangeWithOrderByLimit()
                                    throws Exception

Throws:

Exception

testNoExchangeWithLateralsDownStreamJoin

public void testNoExchangeWithLateralsDownStreamJoin()
                                              throws Exception

Throws:

Exception

testNoExchangeWithLateralsDownStreamUnion

public void testNoExchangeWithLateralsDownStreamUnion()
                                               throws Exception

Throws:

Exception

testNoExchangeWithLateralsDownStreamAgg

public void testNoExchangeWithLateralsDownStreamAgg()
                                             throws Exception

Throws:

Exception

testLateralAndUnnestExplainPlan

public void testLateralAndUnnestExplainPlan()
                                     throws Exception

Throws:

Exception

testUnnestTopN

public void testUnnestTopN()
                    throws Exception

Throws:

Exception

testMultiUnnestQuery

public void testMultiUnnestQuery()
                          throws Exception

Throws:

Exception

testNestedColumnQuery

public void testNestedColumnQuery()
                           throws Exception

Throws:

Exception