org.apache.drill.exec.physical.impl.orderedpartitioner

Class TestOrderedPartitionExchange

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.ExecTest

org.apache.drill.exec.pop.PopUnitTestBase

org.apache.drill.exec.physical.impl.orderedpartitioner.TestOrderedPartitionExchange

public class TestOrderedPartitionExchange
extends PopUnitTestBase

Tests the OrderedPartitionExchange Operator

Nested Class Summary

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

DrillTest.MemWatcher

Field Summary

Fields inherited from class org.apache.drill.exec.pop.PopUnitTestBase

CONFIG

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

Method Summary

Modifier and Type	Method and Description
void	twoBitTwoExchangeRun() Starts two drillbits and runs a physical plan with a Mock scan, project, OrderedParititionExchange, Union Exchange, and sort.

Methods inherited from class org.apache.drill.exec.pop.PopUnitTestBase

getFragmentCount, getRootFragment, getRootFragmentFromPlanString, setup

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

TestOrderedPartitionExchange

public TestOrderedPartitionExchange()

Method Detail

twoBitTwoExchangeRun

public void twoBitTwoExchangeRun()
                          throws Exception

Starts two drillbits and runs a physical plan with a Mock scan, project, OrderedParititionExchange, Union Exchange, and sort. The final sort is done first on the partition column, and verifies that the partitions are correct, in that all rows in partition 0 should come in the sort order before any row in partition 1, etc. Also verifies that the standard deviation of the size of the partitions is less than one tenth the mean size of the partitions, because we expect all the partitions to be roughly equal in size.

Throws:

Exception