org.apache.drill.exec.physical.impl.xsort

Class TestCopier

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.SubOperatorTest

org.apache.drill.exec.physical.impl.xsort.TestCopier

public class TestCopier
extends SubOperatorTest

Light-weight sanity test of the copier class. The implementation has been used in production, so the tests here just check for the obvious cases.

Note, however, that if significant changes are made to the copier, then additional tests should be added to re-validate the code.

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.test.SubOperatorTest

dirTestWatcher, fixture

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

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestCopier()

Method Summary

Modifier and Type	Method and Description
static RowSet.SingleRowSet	makeDataSet(TupleMetadata schema, int first, int step, int count)
static void	runTypeTest(OperatorFixture fixture, TypeProtos.MinorType type)
static void	testAllTypes(OperatorFixture fixture)
void	testAscNullsFirst()
void	testAscNullsLast()
void	testDescNullsFirst()
void	testDescNullsLast()
void	testEmptyBatch()
void	testEmptyInput()
void	testMapType()
void	testMapType(OperatorFixture fixture)
void	testMultipleOutput()
void	testMultipleOutputDesc()
void	testSingleRow()
void	testTwoBatchesSingleRow()
void	testTypes()

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

classSetup, classTeardown

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

TestCopier

public TestCopier()

Method Detail

testEmptyInput

public void testEmptyInput()

testEmptyBatch

public void testEmptyBatch()
                    throws Exception

Throws:

Exception

testSingleRow

public void testSingleRow()
                   throws Exception

Throws:

Exception

testTwoBatchesSingleRow

public void testTwoBatchesSingleRow()
                             throws Exception

Throws:

Exception

makeDataSet

public static RowSet.SingleRowSet makeDataSet(TupleMetadata schema,
                                              int first,
                                              int step,
                                              int count)

testMultipleOutput

public void testMultipleOutput()
                        throws Exception

Throws:

Exception

testMultipleOutputDesc

public void testMultipleOutputDesc()
                            throws Exception

Throws:

Exception

testAscNullsLast

public void testAscNullsLast()
                      throws Exception

Throws:

Exception

testAscNullsFirst

public void testAscNullsFirst()
                       throws Exception

Throws:

Exception

testDescNullsLast

public void testDescNullsLast()
                       throws Exception

Throws:

Exception

testDescNullsFirst

public void testDescNullsFirst()
                        throws Exception

Throws:

Exception

runTypeTest

public static void runTypeTest(OperatorFixture fixture,
                               TypeProtos.MinorType type)
                        throws Exception

Throws:

Exception

testTypes

public void testTypes()
               throws Exception

Throws:

Exception

testAllTypes

public static void testAllTypes(OperatorFixture fixture)
                         throws Exception

Throws:

Exception

testMapType

public void testMapType()
                 throws Exception

Throws:

Exception

testMapType

public void testMapType(OperatorFixture fixture)
                 throws Exception

Throws:

Exception