org.apache.drill.exec.physical.impl

Class TestOrderedMuxExchange

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.PlanTestBase

org.apache.drill.exec.physical.impl.TestOrderedMuxExchange

public class TestOrderedMuxExchange
extends PlanTestBase

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.PlanTestBase

EXPECTED_NOT_FOUND, JSON_FORMAT, OPTIQ_FORMAT, UNEXPECTED_FOUND

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
TestOrderedMuxExchange()

Method Summary

Modifier and Type	Method and Description
static void	generateTestDataAndQueries() Generate data for two tables.
void	testLimitOnOrderedMux() Test case to verify the OrderedMuxExchange created for order by with limit.
void	testLimitOnOrderedMuxWindow() Test case to verify the OrderedMuxExchange created for order by with limit and window agg.
void	testOrderedMuxForOrderBy() Test case to verify the OrderedMuxExchange created for order by clause.
void	testOrderedMuxForWindowAgg() Test case to verify the OrderedMuxExchange created for window functions.

Methods inherited from class org.apache.drill.PlanTestBase

checkForMetadataFile, createMetadataDir, getPhysicalJsonPlan, getPlanInString, testPhysicalPlan, testPhysicalPlanExecutionBasedOnQuery, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanOneExcludedPattern, testPlanOneExpectedPattern, testPlanOneExpectedPatternOneExcluded, testPlanSubstrPatterns, testPlanWithAttributesMatchingPatterns, testRelLogicalJoinOrder, testRelLogicalPlanLevDigest, testRelLogicalPlanLevExplain, testRelPhysicalJoinOrder, testRelPhysicalPlanLevDigest, testRelPhysicalPlanLevExplain

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

TestOrderedMuxExchange

public TestOrderedMuxExchange()

Method Detail

generateTestDataAndQueries

public static void generateTestDataAndQueries()
                                       throws Exception

Generate data for two tables. Each table consists of several JSON files.

Throws:

Exception

testOrderedMuxForOrderBy

public void testOrderedMuxForOrderBy()
                              throws Exception

Test case to verify the OrderedMuxExchange created for order by clause. It checks by forcing the plan to create OrderedMuxExchange and also verifies the output column is ordered.

Throws:

Exception - if anything goes wrong

testOrderedMuxForWindowAgg

public void testOrderedMuxForWindowAgg()
                                throws Exception

Test case to verify the OrderedMuxExchange created for window functions. It checks by forcing the plan to create OrderedMuxExchange and also verifies the output column is ordered.

Throws:

Exception - if anything goes wrong

testLimitOnOrderedMux

public void testLimitOnOrderedMux()
                           throws Exception

Test case to verify the OrderedMuxExchange created for order by with limit. It checks that the limit is pushed down the OrderedMuxExchange.

Throws:

Exception - if anything goes wrong

testLimitOnOrderedMuxWindow

public void testLimitOnOrderedMuxWindow()
                                 throws Exception

Test case to verify the OrderedMuxExchange created for order by with limit and window agg. It checks that the limit is pushed down the OrderedMuxExchange.

Throws:

Exception - if anything goes wrong