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

Class JoinTestBase

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.exec.ExecTest

org.apache.drill.test.BaseTestQuery

org.apache.drill.PlanTestBase

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

Direct Known Subclasses:

TestHashJoinAdvanced, TestHashJoinJPPDPlan, TestJoinEmptyDirTable, TestMergeJoinAdvanced, TestNestedLoopJoin

public class JoinTestBase
extends PlanTestBase

Nested Class Summary

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

BaseTestQuery.ClassicTestServices, BaseTestQuery.SilentListener, BaseTestQuery.TestResultSet

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

DrillTest.MemWatcher

Field Summary

Fields

Modifier and Type	Field and Description
static String	DISABLE_HJ
static String	DISABLE_JOIN_OPTIMIZATION
static String	DISABLE_MJ
static String	DISABLE_NLJ_SCALAR
static String	ENABLE_HJ
static String	ENABLE_MJ
static String	ENABLE_NLJ_SCALAR
static String	HJ_PATTERN
static String	INNER_JOIN_TYPE
static String	LEFT_JOIN_TYPE
static String	MJ_PATTERN
static String	NLJ_PATTERN
static String	RESET_HJ
static String	RESET_JOIN_OPTIMIZATION
static String	RIGHT_JOIN_TYPE

Fields inherited from class org.apache.drill.PlanTestBase

EXPECTED_NOT_FOUND, JSON_FORMAT, OPTIQ_FORMAT, UNEXPECTED_FOUND

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

allocator, bits, client, config, serviceSet

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

Method Summary

Modifier and Type	Method and Description
static void	enableJoin(boolean hj, boolean mj, boolean nlj) Allows to enable necessary join operator.
static void	resetJoinOptions() Allows to reset session options of custom join operators
void	testJoinWithEmptyFile(File testDir, String joinType, String[] joinPattern, long result) This method runs a join query with one of the table generated as an empty json file.

Methods inherited from class org.apache.drill.PlanTestBase

checkForMetadataFile, createMetadataDir, getPhysicalJsonPlan, getPlanInString, testPhysicalPlan, testPhysicalPlanExecutionBasedOnQuery, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanMatchingPatterns, testPlanOneExcludedPattern, testPlanOneExpectedPattern, testPlanOneExpectedPatternOneExcluded, testPlanSubstrPatterns, testPlanWithAttributesMatchingPatterns, testRelLogicalJoinOrder, testRelLogicalPlanLevDigest, testRelLogicalPlanLevExplain, testRelPhysicalJoinOrder, testRelPhysicalPlanLevDigest, testRelPhysicalPlanLevExplain

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

alterSession, cloneDefaultTestConfigProperties, closeClient, errorMsgTestHelper, getAllocator, getDrillbitContext, getFile, getPhysicalFileFromResource, getResultString, getUserPort, logResult, newTest, parseErrorHelper, printResult, resetAllSessionOptions, resetDrillbitCount, resetSessionOption, runSQL, setColumnWidth, setColumnWidths, setSessionOption, setSessionOption, setSessionOption, setSessionOption, setupDefaultTestCluster, test, test, testBuilder, testLogicalWithResults, testNoResult, testNoResult, testPhysical, testPhysicalFromFile, testPhysicalWithResults, testPreparedStatement, testRunAndPrint, testRunAndReturn, testSql, testSqlWithResults, testWithListener, updateClient, updateClient, updateClient, updateTestCluster, updateTestCluster

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

Field Detail

HJ_PATTERN

public static final String HJ_PATTERN

See Also:

Constant Field Values

MJ_PATTERN

public static final String MJ_PATTERN

See Also:

Constant Field Values

NLJ_PATTERN

public static final String NLJ_PATTERN

See Also:

Constant Field Values

INNER_JOIN_TYPE

public static final String INNER_JOIN_TYPE

See Also:

Constant Field Values

LEFT_JOIN_TYPE

public static final String LEFT_JOIN_TYPE

See Also:

Constant Field Values

RIGHT_JOIN_TYPE

public static final String RIGHT_JOIN_TYPE

See Also:

Constant Field Values

DISABLE_HJ

public static final String DISABLE_HJ

ENABLE_HJ

public static final String ENABLE_HJ

RESET_HJ

public static final String RESET_HJ

DISABLE_MJ

public static final String DISABLE_MJ

ENABLE_MJ

public static final String ENABLE_MJ

DISABLE_NLJ_SCALAR

public static final String DISABLE_NLJ_SCALAR

ENABLE_NLJ_SCALAR

public static final String ENABLE_NLJ_SCALAR

DISABLE_JOIN_OPTIMIZATION

public static final String DISABLE_JOIN_OPTIMIZATION

RESET_JOIN_OPTIMIZATION

public static final String RESET_JOIN_OPTIMIZATION

Constructor Detail

JoinTestBase

public JoinTestBase()

Method Detail

testJoinWithEmptyFile

public void testJoinWithEmptyFile(File testDir,
                                  String joinType,
                                  String[] joinPattern,
                                  long result)
                           throws Exception

This method runs a join query with one of the table generated as an empty json file.

Parameters:

testDir - in which the empty json file is generated.

joinType - to be executed.

joinPattern - to look for the pattern in the successful run.

result - number of the output rows.

Throws:

Exception

enableJoin

public static void enableJoin(boolean hj,
                              boolean mj,
                              boolean nlj)
                       throws Exception

Allows to enable necessary join operator.

Parameters:

hj - hash join operator

mj - merge join operator

nlj - nested-loop join operator

Throws:

Exception - If any exception is obtained, all set options should be reset

resetJoinOptions

public static void resetJoinOptions()

Allows to reset session options of custom join operators