org.apache.drill.exec.store.parquet

Class TestParquetMetadataCache

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.store.parquet.TestParquetMetadataCache

public class TestParquetMetadataCache
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 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
TestParquetMetadataCache()

Method Summary

Modifier and Type	Method and Description
static void	copyData()
void	testAbsentPluginOrWorkspaceError()
void	testAutoRefreshPartitionPruning()
void	testAutoRefreshWithInterestingColumn()
void	testAutoRefreshWithInterestingColumnFile()
void	testBooleanPartitionPruning()
void	testCache()
void	testCacheWithSubschema()
void	testCorruptedMetadataFile()
void	testDefaultRefresh()
void	testDrill4530_1()
void	testDrill4530_2()
void	testDrill4530_3()
void	testDrill4530_4()
void	testDrill4786_1()
void	testDrill4786_2()
void	testDrill4794()
void	testDrill4877()
void	testEmptyDirectoryWithMetadataDirFile()
void	testEmptyDirectoryWithMetadataFile()
void	testEmptyMetadataFile()
void	testFix4449()
void	testFutureUnsupportedMetadataVersion()
void	testInnerMetadataFilesAreAbsent()
void	testIntervalDayPartitionPruning()
void	testIntervalYearPartitionPruning()
void	testIntWithNullsPartitionPruning()
void	testMetadataCacheFieldWithDots()
void	testMoveCache()
void	testNoSupportedError()
void	testOldMetadataVersions()
void	testPartitionPruningWithIsNotNull()
void	testPartitionPruningWithIsNull()
void	testPartitionPruningWithMetadataCache_1()
void	testPartitionPruningWithMetadataCache_2()
void	testPartitionPruningWithMetadataCache_3()
void	testPartitionPruningWithMetadataCache_4()
void	testRefreshDefault()
void	testRefreshExistentColumns()
void	testRefreshNone()
void	testRefreshNonExAndNonIntColumnFilter()
void	testRefreshNonExistentColumnFilter()
void	testRefreshNonExistentColumns()
void	testRefreshNonInterestingColumns()
void	testRefreshSchemaChange()
void	testRefreshWithColumns()
void	testRefreshWithDictColumn()
void	testRefreshWithInterestingColumn()
void	testRefreshWithIsNull()
void	testRootMetadataFileIsAbsent()
void	testSpacesInMetadataCachePath()
void	testTableDoesNotExistWithEmptyDirectory()
void	testTableDoesNotExistWithIncorrectTableName()
void	testTotalRowCount()
void	testTotalRowCountAddDirectory()
void	testTotalRowCountAddFile()
void	testTotalRowCountAddSubDir()
void	testTotalRowCountSubDir()
void	testUpdate()

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

Constructor Detail

TestParquetMetadataCache

public TestParquetMetadataCache()

Method Detail

copyData

public static void copyData()

testPartitionPruningWithMetadataCache_1

public void testPartitionPruningWithMetadataCache_1()
                                             throws Exception

Throws:

Exception

testPartitionPruningWithMetadataCache_2

public void testPartitionPruningWithMetadataCache_2()
                                             throws Exception

Throws:

Exception

testPartitionPruningWithMetadataCache_3

public void testPartitionPruningWithMetadataCache_3()
                                             throws Exception

Throws:

Exception

testPartitionPruningWithMetadataCache_4

public void testPartitionPruningWithMetadataCache_4()
                                             throws Exception

Throws:

Exception

testCache

public void testCache()
               throws Exception

Throws:

Exception

testUpdate

public void testUpdate()
                throws Exception

Throws:

Exception

testCacheWithSubschema

public void testCacheWithSubschema()
                            throws Exception

Throws:

Exception

testFix4449

public void testFix4449()
                 throws Exception

Throws:

Exception

testAbsentPluginOrWorkspaceError

public void testAbsentPluginOrWorkspaceError()
                                      throws Exception

Throws:

Exception

testTableDoesNotExistWithEmptyDirectory

public void testTableDoesNotExistWithEmptyDirectory()
                                             throws Exception

Throws:

Exception

testTableDoesNotExistWithIncorrectTableName

public void testTableDoesNotExistWithIncorrectTableName()
                                                 throws Exception

Throws:

Exception

testNoSupportedError

public void testNoSupportedError()
                          throws Exception

Throws:

Exception

testDrill4530_1

public void testDrill4530_1()
                     throws Exception

Throws:

Exception

testDrill4530_2

public void testDrill4530_2()
                     throws Exception

Throws:

Exception

testDrill4530_3

public void testDrill4530_3()
                     throws Exception

Throws:

Exception

testDrill4530_4

public void testDrill4530_4()
                     throws Exception

Throws:

Exception

testDrill4794

public void testDrill4794()
                   throws Exception

Throws:

Exception

testDrill4786_1

public void testDrill4786_1()
                     throws Exception

Throws:

Exception

testDrill4786_2

public void testDrill4786_2()
                     throws Exception

Throws:

Exception

testDrill4877

public void testDrill4877()
                   throws Exception

Throws:

Exception

testMoveCache

public void testMoveCache()
                   throws Exception

Throws:

Exception

testOldMetadataVersions

public void testOldMetadataVersions()
                             throws Exception

Throws:

Exception

testSpacesInMetadataCachePath

public void testSpacesInMetadataCachePath()
                                   throws Exception

Throws:

Exception

testFutureUnsupportedMetadataVersion

public void testFutureUnsupportedMetadataVersion()
                                          throws Exception

Throws:

Exception

testCorruptedMetadataFile

public void testCorruptedMetadataFile()
                               throws Exception

Throws:

Exception

testEmptyMetadataFile

public void testEmptyMetadataFile()
                           throws Exception

Throws:

Exception

testRootMetadataFileIsAbsent

public void testRootMetadataFileIsAbsent()
                                  throws Exception

Throws:

Exception

testInnerMetadataFilesAreAbsent

public void testInnerMetadataFilesAreAbsent()
                                     throws Exception

Throws:

Exception

testMetadataCacheFieldWithDots

public void testMetadataCacheFieldWithDots()
                                    throws Exception

Throws:

Exception

testBooleanPartitionPruning

public void testBooleanPartitionPruning()
                                 throws Exception

Throws:

Exception

testIntervalDayPartitionPruning

public void testIntervalDayPartitionPruning()
                                     throws Exception

Throws:

Exception

testIntervalYearPartitionPruning

public void testIntervalYearPartitionPruning()
                                      throws Exception

Throws:

Exception

testIntWithNullsPartitionPruning

public void testIntWithNullsPartitionPruning()
                                      throws Exception

Throws:

Exception

testPartitionPruningWithIsNull

public void testPartitionPruningWithIsNull()
                                    throws Exception

Throws:

Exception

testPartitionPruningWithIsNotNull

public void testPartitionPruningWithIsNotNull()
                                       throws Exception

Throws:

Exception

testEmptyDirectoryWithMetadataFile

public void testEmptyDirectoryWithMetadataFile()
                                        throws Exception

Throws:

Exception

testEmptyDirectoryWithMetadataDirFile

public void testEmptyDirectoryWithMetadataDirFile()
                                           throws Exception

Throws:

Exception

testAutoRefreshPartitionPruning

public void testAutoRefreshPartitionPruning()
                                     throws Exception

Throws:

Exception

testRefreshDefault

public void testRefreshDefault()
                        throws Exception

Throws:

Exception

testRefreshWithColumns

public void testRefreshWithColumns()
                            throws Exception

Throws:

Exception

testRefreshNone

public void testRefreshNone()
                     throws Exception

Throws:

Exception

testTotalRowCount

public void testTotalRowCount()
                       throws Exception

Throws:

Exception

testTotalRowCountSubDir

public void testTotalRowCountSubDir()
                             throws Exception

Throws:

Exception

testTotalRowCountAddDirectory

public void testTotalRowCountAddDirectory()
                                   throws Exception

Throws:

Exception

testTotalRowCountAddSubDir

public void testTotalRowCountAddSubDir()
                                throws Exception

Throws:

Exception

testTotalRowCountAddFile

public void testTotalRowCountAddFile()
                              throws Exception

Throws:

Exception

testRefreshWithInterestingColumn

public void testRefreshWithInterestingColumn()
                                      throws Exception

Throws:

Exception

testDefaultRefresh

public void testDefaultRefresh()
                        throws Exception

Throws:

Exception

testAutoRefreshWithInterestingColumn

public void testAutoRefreshWithInterestingColumn()
                                          throws Exception

Throws:

Exception

testAutoRefreshWithInterestingColumnFile

public void testAutoRefreshWithInterestingColumnFile()
                                              throws Exception

Throws:

Exception

testRefreshWithIsNull

public void testRefreshWithIsNull()
                           throws Exception

Throws:

Exception

testRefreshExistentColumns

public void testRefreshExistentColumns()
                                throws Exception

Throws:

Exception

testRefreshNonExistentColumns

public void testRefreshNonExistentColumns()
                                   throws Exception

Throws:

Exception

testRefreshNonExistentColumnFilter

public void testRefreshNonExistentColumnFilter()
                                        throws Exception

Throws:

Exception

testRefreshNonExAndNonIntColumnFilter

public void testRefreshNonExAndNonIntColumnFilter()
                                           throws Exception

Throws:

Exception

testRefreshNonInterestingColumns

public void testRefreshNonInterestingColumns()
                                      throws Exception

Throws:

Exception

testRefreshSchemaChange

public void testRefreshSchemaChange()
                             throws Exception

Throws:

Exception

testRefreshWithDictColumn

public void testRefreshWithDictColumn()
                               throws Exception

Throws:

Exception