org.apache.drill.exec.physical.unit

Class TestOutputBatchSize

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.ExecTest

org.apache.drill.test.PhysicalOpUnitTestBase

org.apache.drill.exec.physical.unit.TestOutputBatchSize

public class TestOutputBatchSize
extends PhysicalOpUnitTestBase

Nested Class Summary

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

PhysicalOpUnitTestBase.BatchIterator, PhysicalOpUnitTestBase.MockExecutorFragmentContext, PhysicalOpUnitTestBase.MockPhysicalOperator

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

DrillTest.MemWatcher

Field Summary

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

classpathScan, dirTestWatcher, drillbitContext, drillConf, fragContext, opContext, opCreatorReg, operatorFixture, scanDecodeExecutor, scanExecutor

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

c, optionManager

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

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestOutputBatchSize()

Method Summary

Modifier and Type	Method and Description
void	testFlattenEmptyList()
void	testFlattenFixedWidth()
void	testFlattenFixedWidthList()
void	testFlattenLargeRecords()
void	testFlattenListOfMaps()
void	testFlattenLowerLimit()
void	testFlattenMap()
void	testFlattenNestedMap()
void	testFlattenUpperLimit()
void	testFlattenVariableWidth()
void	testFlattenVariableWidthList()
void	testHashAggAvg()
void	testHashAggMax()
void	testHashAggSum()
void	testHashJoinLowerLimit()
void	testHashJoinMultipleOutputBatches()
void	testHashJoinSingleOutputBatch()
void	testHashJoinUpperLimit()
void	testLeftNestedLoopJoin()
void	testLeftOuterHashJoin()
void	testMergeJoinLowerLimit()
void	testMergeJoinMultipleOutputBatches()
void	testMergeJoinSingleOutputBatch()
void	testMergeJoinUpperLimit()
void	testNestedLoopJoinLowerLimit()
void	testNestedLoopJoinMultipleOutputBatches()
void	testNestedLoopJoinSingleOutputBatch()
void	testNestedLoopJoinUpperLimit()
void	testProjectFixedWidthImpl(boolean transfer, int columnCount) Tests BatchSizing of fixed-width transfers and new column creations in Project.
void	testProjectFixedWidthNewColumn()
void	testProjectFixedWidthTransfer()
void	testProjectMap()
void	testProjectVariableWidthFunctions()
void	testProjectVariableWidthImpl(boolean transfer, int columnCount, String testString)
void	testProjectVariableWidthMixed() Test expression with transfer and new columns
void	testProjectVariableWidthNewColumn()
void	testProjectVariableWidthTransfer()
void	testProjectZeroWidth()
void	testRightOuterHashJoin()
void	testSimpleHashAgg()
void	testSizerRepeatedList()
void	testSizerRepeatedRepeatedList()
void	testUnionLowerLimit()
void	testUnionMultipleOutputBatches()
void	testUnionOutputBatch()

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

getJsonReadersFromBatchString, getJsonReadersFromInputFiles, getOpCreatorReg, getReaderListForJsonBatches, joinCond, legacyOpTestBuilder, mockFragmentContext, mockOpContext, opTestBuilder, ordering, parseExprs, setup, teardown

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

TestOutputBatchSize

public TestOutputBatchSize()

Method Detail

testProjectMap

public void testProjectMap()
                    throws Exception

Throws:

Exception

testProjectVariableWidthFunctions

public void testProjectVariableWidthFunctions()
                                       throws Exception

Throws:

Exception

testProjectFixedWidthTransfer

public void testProjectFixedWidthTransfer()
                                   throws Exception

Throws:

Exception

testProjectFixedWidthNewColumn

public void testProjectFixedWidthNewColumn()
                                    throws Exception

Throws:

Exception

testProjectFixedWidthImpl

public void testProjectFixedWidthImpl(boolean transfer,
                                      int columnCount)
                               throws Exception

Tests BatchSizing of fixed-width transfers and new column creations in Project. Transfer: Evaluates 'select *' New Columns: Evalutes 'select C0 + 5 as C0 ... C[columnCount] + 5 as C[columnCount]

Parameters:

transfer -

Throws:

Exception

testProjectVariableWidthTransfer

public void testProjectVariableWidthTransfer()
                                      throws Exception

Throws:

Exception

testProjectVariableWidthNewColumn

public void testProjectVariableWidthNewColumn()
                                       throws Exception

Throws:

Exception

testProjectZeroWidth

public void testProjectZeroWidth()
                          throws Exception

Throws:

Exception

testProjectVariableWidthImpl

public void testProjectVariableWidthImpl(boolean transfer,
                                         int columnCount,
                                         String testString)
                                  throws Exception

Throws:

Exception

testProjectVariableWidthMixed

public void testProjectVariableWidthMixed()
                                   throws Exception

Test expression with transfer and new columns

Throws:

Exception

testFlattenFixedWidth

public void testFlattenFixedWidth()
                           throws Exception

Throws:

Exception

testFlattenVariableWidth

public void testFlattenVariableWidth()
                              throws Exception

Throws:

Exception

testFlattenFixedWidthList

public void testFlattenFixedWidthList()
                               throws Exception

Throws:

Exception

testFlattenVariableWidthList

public void testFlattenVariableWidthList()
                                  throws Exception

Throws:

Exception

testFlattenMap

public void testFlattenMap()
                    throws Exception

Throws:

Exception

testFlattenListOfMaps

public void testFlattenListOfMaps()
                           throws Exception

Throws:

Exception

testFlattenNestedMap

public void testFlattenNestedMap()
                          throws Exception

Throws:

Exception

testFlattenUpperLimit

public void testFlattenUpperLimit()
                           throws Exception

Throws:

Exception

testFlattenLowerLimit

public void testFlattenLowerLimit()
                           throws Exception

Throws:

Exception

testFlattenEmptyList

public void testFlattenEmptyList()
                          throws Exception

Throws:

Exception

testFlattenLargeRecords

public void testFlattenLargeRecords()
                             throws Exception

Throws:

Exception

testMergeJoinMultipleOutputBatches

public void testMergeJoinMultipleOutputBatches()
                                        throws Exception

Throws:

Exception

testMergeJoinSingleOutputBatch

public void testMergeJoinSingleOutputBatch()
                                    throws Exception

Throws:

Exception

testMergeJoinUpperLimit

public void testMergeJoinUpperLimit()
                             throws Exception

Throws:

Exception

testMergeJoinLowerLimit

public void testMergeJoinLowerLimit()
                             throws Exception

Throws:

Exception

testUnionOutputBatch

public void testUnionOutputBatch()
                          throws Exception

Throws:

Exception

testUnionMultipleOutputBatches

public void testUnionMultipleOutputBatches()
                                    throws Exception

Throws:

Exception

testUnionLowerLimit

public void testUnionLowerLimit()
                         throws Exception

Throws:

Exception

testHashJoinMultipleOutputBatches

public void testHashJoinMultipleOutputBatches()
                                       throws Exception

Throws:

Exception

testHashJoinSingleOutputBatch

public void testHashJoinSingleOutputBatch()
                                   throws Exception

Throws:

Exception

testHashJoinUpperLimit

public void testHashJoinUpperLimit()
                            throws Exception

Throws:

Exception

testHashJoinLowerLimit

public void testHashJoinLowerLimit()
                            throws Exception

Throws:

Exception

testRightOuterHashJoin

public void testRightOuterHashJoin()
                            throws Exception

Throws:

Exception

testLeftOuterHashJoin

public void testLeftOuterHashJoin()
                           throws Exception

Throws:

Exception

testSimpleHashAgg

public void testSimpleHashAgg()

testHashAggSum

public void testHashAggSum()
                    throws ExecutionSetupException

Throws:

ExecutionSetupException

testHashAggAvg

public void testHashAggAvg()
                    throws ExecutionSetupException

Throws:

ExecutionSetupException

testHashAggMax

public void testHashAggMax()
                    throws ExecutionSetupException

Throws:

ExecutionSetupException

testNestedLoopJoinMultipleOutputBatches

public void testNestedLoopJoinMultipleOutputBatches()
                                             throws Exception

Throws:

Exception

testNestedLoopJoinSingleOutputBatch

public void testNestedLoopJoinSingleOutputBatch()
                                         throws Exception

Throws:

Exception

testNestedLoopJoinUpperLimit

public void testNestedLoopJoinUpperLimit()
                                  throws Exception

Throws:

Exception

testNestedLoopJoinLowerLimit

public void testNestedLoopJoinLowerLimit()
                                  throws Exception

Throws:

Exception

testLeftNestedLoopJoin

public void testLeftNestedLoopJoin()
                            throws Exception

Throws:

Exception

testSizerRepeatedList

public void testSizerRepeatedList()
                           throws Exception

Throws:

Exception

testSizerRepeatedRepeatedList

public void testSizerRepeatedRepeatedList()
                                   throws Exception

Throws:

Exception