org.apache.drill.exec.physical.impl.join

Class TestLateralJoinCorrectnessBatchProcessing

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.SubOperatorTest

org.apache.drill.exec.physical.impl.join.TestLateralJoinCorrectnessBatchProcessing

public class TestLateralJoinCorrectnessBatchProcessing
extends SubOperatorTest

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

Method Summary

Modifier and Type	Method and Description
void	afterTest()
void	beforeTest()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testLeftAndRight_OutputFull_InRightBatchMiddle()
void	testLeftAndRight_OutputFull_WithPendingLeftRow_LeftJoin()
void	testLeftAndRight_OutputFull_WithPendingLeftRow()
void	testLeftAndRightAllMatchingRows_MultipleBatch()
void	testLeftAndRightAllMatchingRows_SecondBatch_Empty()
void	testLeftAndRightAllMatchingRows_SingleBatch()
void	testLeftAndRightWithInitialMissingRows_LeftJoin_MultipleBatch()
void	testLeftAndRightWithInitialMissingRows_MultipleBatch()
void	testLeftAndRightWithLastMissingRows_LeftJoin_MultipleBatch()
void	testLeftAndRightWithLastMissingRows_MultipleBatch()
void	testLeftAndRightWithMissingRows_LeftJoin_SingleBatch()
void	testLeftAndRightWithMissingRows_SingleBatch()
void	testMultipleLeftAndRight_OutputFull_WithPendingLeftRow_LeftJoin()

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

TestLateralJoinCorrectnessBatchProcessing

public TestLateralJoinCorrectnessBatchProcessing()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

beforeTest

public void beforeTest()
                throws Exception

Throws:

Exception

afterTest

public void afterTest()
               throws Exception

Throws:

Exception

testLeftAndRightAllMatchingRows_SingleBatch

public void testLeftAndRightAllMatchingRows_SingleBatch()
                                                 throws Exception

Throws:

Exception

testLeftAndRightAllMatchingRows_MultipleBatch

public void testLeftAndRightAllMatchingRows_MultipleBatch()
                                                   throws Exception

Throws:

Exception

testLeftAndRightAllMatchingRows_SecondBatch_Empty

public void testLeftAndRightAllMatchingRows_SecondBatch_Empty()
                                                       throws Exception

Throws:

Exception

testLeftAndRightWithMissingRows_SingleBatch

public void testLeftAndRightWithMissingRows_SingleBatch()
                                                 throws Exception

Throws:

Exception

testLeftAndRightWithMissingRows_LeftJoin_SingleBatch

public void testLeftAndRightWithMissingRows_LeftJoin_SingleBatch()
                                                          throws Exception

Throws:

Exception

testLeftAndRightWithInitialMissingRows_MultipleBatch

public void testLeftAndRightWithInitialMissingRows_MultipleBatch()
                                                          throws Exception

Throws:

Exception

testLeftAndRightWithInitialMissingRows_LeftJoin_MultipleBatch

public void testLeftAndRightWithInitialMissingRows_LeftJoin_MultipleBatch()
                                                                   throws Exception

Throws:

Exception

testLeftAndRightWithLastMissingRows_MultipleBatch

public void testLeftAndRightWithLastMissingRows_MultipleBatch()
                                                       throws Exception

Throws:

Exception

testLeftAndRightWithLastMissingRows_LeftJoin_MultipleBatch

public void testLeftAndRightWithLastMissingRows_LeftJoin_MultipleBatch()
                                                                throws Exception

Throws:

Exception

testLeftAndRight_OutputFull_InRightBatchMiddle

public void testLeftAndRight_OutputFull_InRightBatchMiddle()
                                                    throws Exception

Throws:

Exception

testLeftAndRight_OutputFull_WithPendingLeftRow

public void testLeftAndRight_OutputFull_WithPendingLeftRow()
                                                    throws Exception

Throws:

Exception

testLeftAndRight_OutputFull_WithPendingLeftRow_LeftJoin

public void testLeftAndRight_OutputFull_WithPendingLeftRow_LeftJoin()
                                                             throws Exception

Throws:

Exception

testMultipleLeftAndRight_OutputFull_WithPendingLeftRow_LeftJoin

public void testMultipleLeftAndRight_OutputFull_WithPendingLeftRow_LeftJoin()
                                                                     throws Exception

Throws:

Exception