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

Class TestHashJoinJPPDCorrectness

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.ClusterTest

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

public class TestHashJoinJPPDCorrectness
extends ClusterTest

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

client, cluster, dirTestWatcher

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

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestHashJoinJPPDCorrectness()

Method Summary

Modifier and Type	Method and Description
static void	setUp()
void	tearDown()
void	testDifferentOrderOfJoinAndFilterCondition_filterConditionFirst() Verifies that result of query doesn't change if filter and join condition order is different in test query with RuntimeFilter and baseline query without RuntimeFilter.
void	testDifferentOrderOfJoinAndFilterCondition_filterConditionSecond() Verifies that result of query with join condition and filter condition is same with or without RuntimeFilter.
void	testDifferentOrderOfJoinAndFilterConditionAndRTF() Verifies that result of query doesn't change if filter and join condition order is different in test query with RuntimeFilter and baseline query with RuntimeFilter.
void	testHashJoinCorrectnessWithRuntimeFilter() Verifies that result of a query with join condition doesn't changes with and without Runtime Filter for correctness
void	testRuntimeFilterPresentInPlan() Test to make sure runtime filter is inserted in the plan.
void	testSameOrderOfJoinAndFilterConditionProduceSameResult() Verifies that result of query with join condition and filter condition is same with or without RuntimeFilter.

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

getFile, queryBuilder, run, runAndLog, runAndPrint, runAndPrint, shutdown, startCluster, testBuilder

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

TestHashJoinJPPDCorrectness

public TestHashJoinJPPDCorrectness()

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public void tearDown()

testRuntimeFilterPresentInPlan

public void testRuntimeFilterPresentInPlan()
                                    throws Exception

Test to make sure runtime filter is inserted in the plan. This is to ensure that with current cluster setup and system options distributed plan is generated rather than single fragment plan. Since in later case RuntimeFilter will not be inserted.

Throws:

Exception

testHashJoinCorrectnessWithRuntimeFilter

public void testHashJoinCorrectnessWithRuntimeFilter()
                                              throws Exception

Verifies that result of a query with join condition doesn't changes with and without Runtime Filter for correctness

Throws:

Exception

testSameOrderOfJoinAndFilterConditionProduceSameResult

public void testSameOrderOfJoinAndFilterConditionProduceSameResult()
                                                            throws Exception

Verifies that result of query with join condition and filter condition is same with or without RuntimeFilter. In this case order of join and filter condition is same for both test and baseline query

Throws:

Exception

testDifferentOrderOfJoinAndFilterCondition_filterConditionSecond

public void testDifferentOrderOfJoinAndFilterCondition_filterConditionSecond()
                                                                      throws Exception

Verifies that result of query with join condition and filter condition is same with or without RuntimeFilter. In this case order of join and filter condition is swapped between test and baseline query. Also the filter condition is second in case of test query

Throws:

Exception

testDifferentOrderOfJoinAndFilterCondition_filterConditionFirst

public void testDifferentOrderOfJoinAndFilterCondition_filterConditionFirst()
                                                                     throws Exception

Verifies that result of query doesn't change if filter and join condition order is different in test query with RuntimeFilter and baseline query without RuntimeFilter. In this case the filter condition is first condition in test query with RuntimeFilter

Throws:

Exception

testDifferentOrderOfJoinAndFilterConditionAndRTF

public void testDifferentOrderOfJoinAndFilterConditionAndRTF()
                                                      throws Exception

Verifies that result of query doesn't change if filter and join condition order is different in test query with RuntimeFilter and baseline query with RuntimeFilter. In this case both test and baseline query has RuntimeFilter in it.

Throws:

Exception