org.apache.drill.exec.hive

Class TestHiveStorage

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.hive.HiveTestBase

org.apache.drill.exec.hive.TestHiveStorage

public class TestHiveStorage
extends HiveTestBase

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
org.junit.rules.ExpectedException	thrown

Fields inherited from class org.apache.drill.exec.hive.HiveTestBase

HIVE_TEST_FIXTURE

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

Method Summary

Modifier and Type	Method and Description
static void	cleanup()
void	convertFromOnHiveBinaryType()
void	hiveReadWithDb()
static void	init()
void	orderByOnHiveTable()
void	queryEmptyHiveTable()
void	queryingHiveAvroTable()
void	queryingTablesInNonDefaultFS()
void	queryingTableWithSerDeInHiveContribJar()
void	readAllSupportedHiveDataTypes() Test to ensure Drill reads the all supported types correctly both normal fields (converted to Nullable types) and partition fields (converted to Required types).
void	readFromAlteredPartitionedTable()
void	readFromAlteredPartitionedTableWithEmptyGroupType()
void	readFromPartitionWithCustomLocation()
void	readingFromLargeTableWithSkipHeaderAndFooter()
void	readingFromSmallTableWithSkipHeaderAndFooter()
void	readingFromStorageHandleBasedTable()
void	testHiveConfPropertiesAtSessionLevel()
void	testIncorrectFooterProperty()
void	testIncorrectHeaderProperty()
void	testNonAsciiStringLiterals()
void	testPhysicalPlanSubmission()
void	testSchemaCaseInsensitive()
void	testSkipHeaderFooterForPartitionedTable()
void	testStringColumnsMetadata()
void	testTableWithEmptyParquet()
void	testTableWithFooterOnly()
void	testTableWithHeaderFooterOnly()
void	testTableWithHeaderOnly()

Methods inherited from class org.apache.drill.exec.hive.HiveTestBase

setUp, tearDown

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

thrown

public org.junit.rules.ExpectedException thrown

Constructor Detail

TestHiveStorage

public TestHiveStorage()

Method Detail

init

public static void init()

cleanup

public static void cleanup()

hiveReadWithDb

public void hiveReadWithDb()
                    throws Exception

Throws:

Exception

queryEmptyHiveTable

public void queryEmptyHiveTable()
                         throws Exception

Throws:

Exception

convertFromOnHiveBinaryType

public void convertFromOnHiveBinaryType()
                                 throws Exception

Throws:

Exception

readAllSupportedHiveDataTypes

public void readAllSupportedHiveDataTypes()
                                   throws Exception

Test to ensure Drill reads the all supported types correctly both normal fields (converted to Nullable types) and partition fields (converted to Required types).

Throws:

Exception

orderByOnHiveTable

public void orderByOnHiveTable()
                        throws Exception

Throws:

Exception

queryingTablesInNonDefaultFS

public void queryingTablesInNonDefaultFS()
                                  throws Exception

Throws:

Exception

queryingHiveAvroTable

public void queryingHiveAvroTable()
                           throws Exception

Throws:

Exception

queryingTableWithSerDeInHiveContribJar

public void queryingTableWithSerDeInHiveContribJar()
                                            throws Exception

Throws:

Exception

readFromPartitionWithCustomLocation

public void readFromPartitionWithCustomLocation()
                                         throws Exception

Throws:

Exception

readFromAlteredPartitionedTable

public void readFromAlteredPartitionedTable()
                                     throws Exception

Throws:

Exception

readFromAlteredPartitionedTableWithEmptyGroupType

public void readFromAlteredPartitionedTableWithEmptyGroupType()
                                                       throws Exception

Throws:

Exception

readingFromStorageHandleBasedTable

public void readingFromStorageHandleBasedTable()
                                        throws Exception

Throws:

Exception

readingFromSmallTableWithSkipHeaderAndFooter

public void readingFromSmallTableWithSkipHeaderAndFooter()
                                                  throws Exception

Throws:

Exception

readingFromLargeTableWithSkipHeaderAndFooter

public void readingFromLargeTableWithSkipHeaderAndFooter()
                                                  throws Exception

Throws:

Exception

testIncorrectHeaderProperty

public void testIncorrectHeaderProperty()
                                 throws Exception

Throws:

Exception

testIncorrectFooterProperty

public void testIncorrectFooterProperty()
                                 throws Exception

Throws:

Exception

testTableWithHeaderOnly

public void testTableWithHeaderOnly()
                             throws Exception

Throws:

Exception

testTableWithFooterOnly

public void testTableWithFooterOnly()
                             throws Exception

Throws:

Exception

testTableWithHeaderFooterOnly

public void testTableWithHeaderFooterOnly()
                                   throws Exception

Throws:

Exception

testSkipHeaderFooterForPartitionedTable

public void testSkipHeaderFooterForPartitionedTable()
                                             throws Exception

Throws:

Exception

testStringColumnsMetadata

public void testStringColumnsMetadata()
                               throws Exception

Throws:

Exception

testNonAsciiStringLiterals

public void testNonAsciiStringLiterals()
                                throws Exception

Throws:

Exception

testPhysicalPlanSubmission

public void testPhysicalPlanSubmission()
                                throws Exception

Throws:

Exception

testHiveConfPropertiesAtSessionLevel

public void testHiveConfPropertiesAtSessionLevel()
                                          throws Exception

Throws:

Exception

testSchemaCaseInsensitive

public void testSchemaCaseInsensitive()
                               throws Exception

Throws:

Exception

testTableWithEmptyParquet

public void testTableWithEmptyParquet()
                               throws Exception

Throws:

Exception