org.apache.drill.exec.sql

Class TestMetastoreCommands

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.ClusterTest

org.apache.drill.exec.sql.TestMetastoreCommands

public class TestMetastoreCommands
extends ClusterTest

Nested Class Summary

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

DrillTest.MemWatcher

Field Summary

Fields

Modifier and Type	Field and Description
static Map<SchemaPath,ColumnStatistics<?>>	DIR0_1994_Q1_SEGMENT_COLUMN_STATISTICS
static Map<SchemaPath,ColumnStatistics<?>>	DIR0_1994_SEGMENT_COLUMN_STATISTICS
static Map<SchemaPath,ColumnStatistics<?>>	TABLE_COLUMN_STATISTICS
static MetadataInfo	TABLE_META_INFO
org.junit.rules.ExpectedException	thrown

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

Method Summary

Modifier and Type	Method and Description
static BaseTableMetadata	getBaseTableMetadata(TableInfo tableInfo, File table)
static BaseTableMetadata	getBaseTableMetadata(TableInfo tableInfo, File table, TupleMetadata schema)
static <T> ColumnStatistics<T>	getColumnStatistics(T minValue, T maxValue, long rowCount, TypeProtos.MinorType minorType)
static long	getMaxLastModified(File file) Returns last modification time for specified file or max last modification time of child files if specified one is a directory.
void	prepare()
static void	setUp()
void	testAnalyzeEmptyNullableParquetTable()
void	testAnalyzeEmptyRequiredParquetTable()
void	testAnalyzeLowerLevelMetadata()
void	testAnalyzeMultilevelTable()
void	testAnalyzeNonEmptyTableWithEmptyFile()
void	testAnalyzeOnView()
void	testAnalyzeWithClassPathSystem()
void	testAnalyzeWithColumns()
void	testAnalyzeWithDisabledFallback()
void	testAnalyzeWithDisabledMetastore()
void	testAnalyzeWithDisabledStatistics()
void	testAnalyzeWithLeadingSlash()
void	testAnalyzeWithMapColumns()
void	testAnalyzeWithNoColumns()
void	testAnalyzeWithNonWritableWorkspace()
void	testAnalyzeWithoutStatisticsWithStatsFile()
void	testAnalyzeWithRootSchema()
void	testAnalyzeWithSampleStatistics()
void	testAnalyzeWithSchema()
void	testAnalyzeWithSchemaError()
void	testBooleanPartitionPruning()
void	testDefaultSegment()
void	testDescribeWithMetastore()
void	testDirPartitionPruning()
void	testDropMetadata()
void	testDropNonExistingMetadata()
void	testFieldWithDots()
void	testIncompleteAnalyzeCommand()
void	testIncorrectAnalyzeCommand()
void	testIncrementalAnalyzeNewChildSegment()
void	testIncrementalAnalyzeNewFile()
void	testIncrementalAnalyzeNewParentSegment()
void	testIncrementalAnalyzeRemovedFile()
void	testIncrementalAnalyzeRemovedNestedSegment()
void	testIncrementalAnalyzeRemovedParentSegment()
void	testIncrementalAnalyzeUnchangedTable()
void	testIncrementalAnalyzeUpdatedFile()
void	testIncrementalAnalyzeWithDifferentMetadataLevel()
void	testIncrementalAnalyzeWithEmptyColumns()
void	testIncrementalAnalyzeWithFewerColumns()
void	testIncrementalAnalyzeWithMoreColumns()
void	testIntWithNullsPartitionPruning()
void	testNonInterestingColumnInFilter()
void	testPartitionPruningBinaryPartition()
void	testPartitionPruningDir1Filter()
void	testPartitionPruningNonExistentPartition()
void	testPartitionPruningRootSegment()
void	testPartitionPruningSingleLeafPartition()
void	testPartitionPruningSingleNonLeafPartition()
void	testPartitionPruningVarCharPartition()
void	testPartitionPruningWithIsNotNull()
void	testPartitionPruningWithIsNull()
void	testSelectAfterAnalyzeWithNonRowGroupLevel()
void	testSelectEmptyRequiredParquetTable()
void	testSelectFromInfoSchemaColumnsWithMetastore()
void	testSelectFromInfoSchemaPartitionsWithMetastore()
void	testSelectFromInfoSchemaTablesWithMetastore()
void	testSelectNonEmptyTableWithEmptyFile()
void	testSelectWithDisabledMetastore()
void	testSelectWithOutdatedMetadataWithNewFile()
void	testSelectWithOutdatedMetadataWithUpdatedFile()
void	testSimpleAnalyze()
void	testTableFunctionForParquet()
void	testTableFunctionWithDrop()
void	testTableMetadataWithLevels()
void	testUseStatistics()

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

Field Detail

TABLE_COLUMN_STATISTICS

public static final Map<SchemaPath,ColumnStatistics<?>> TABLE_COLUMN_STATISTICS

DIR0_1994_SEGMENT_COLUMN_STATISTICS

public static final Map<SchemaPath,ColumnStatistics<?>> DIR0_1994_SEGMENT_COLUMN_STATISTICS

DIR0_1994_Q1_SEGMENT_COLUMN_STATISTICS

public static final Map<SchemaPath,ColumnStatistics<?>> DIR0_1994_Q1_SEGMENT_COLUMN_STATISTICS

TABLE_META_INFO

public static final MetadataInfo TABLE_META_INFO

thrown

public org.junit.rules.ExpectedException thrown

Constructor Detail

TestMetastoreCommands

public TestMetastoreCommands()

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

prepare

public void prepare()

testAnalyzeWithDisabledMetastore

public void testAnalyzeWithDisabledMetastore()
                                      throws Exception

Throws:

Exception

testSelectWithDisabledMetastore

public void testSelectWithDisabledMetastore()
                                     throws Exception

Throws:

Exception

testSimpleAnalyze

public void testSimpleAnalyze()
                       throws Exception

Throws:

Exception

testTableMetadataWithLevels

public void testTableMetadataWithLevels()
                                 throws Exception

Throws:

Exception

testAnalyzeLowerLevelMetadata

public void testAnalyzeLowerLevelMetadata()
                                   throws Exception

Throws:

Exception

testAnalyzeWithColumns

public void testAnalyzeWithColumns()
                            throws Exception

Throws:

Exception

testAnalyzeWithNoColumns

public void testAnalyzeWithNoColumns()
                              throws Exception

Throws:

Exception

testIncrementalAnalyzeWithFewerColumns

public void testIncrementalAnalyzeWithFewerColumns()
                                            throws Exception

Throws:

Exception

testIncrementalAnalyzeWithMoreColumns

public void testIncrementalAnalyzeWithMoreColumns()
                                           throws Exception

Throws:

Exception

testIncrementalAnalyzeWithEmptyColumns

public void testIncrementalAnalyzeWithEmptyColumns()
                                            throws Exception

Throws:

Exception

testIncrementalAnalyzeUnchangedTable

public void testIncrementalAnalyzeUnchangedTable()
                                          throws Exception

Throws:

Exception

testIncrementalAnalyzeNewParentSegment

public void testIncrementalAnalyzeNewParentSegment()
                                            throws Exception

Throws:

Exception

testIncrementalAnalyzeNewChildSegment

public void testIncrementalAnalyzeNewChildSegment()
                                           throws Exception

Throws:

Exception

testIncrementalAnalyzeNewFile

public void testIncrementalAnalyzeNewFile()
                                   throws Exception

Throws:

Exception

testIncrementalAnalyzeRemovedParentSegment

public void testIncrementalAnalyzeRemovedParentSegment()
                                                throws Exception

Throws:

Exception

testIncrementalAnalyzeRemovedNestedSegment

public void testIncrementalAnalyzeRemovedNestedSegment()
                                                throws Exception

Throws:

Exception

testIncrementalAnalyzeRemovedFile

public void testIncrementalAnalyzeRemovedFile()
                                       throws Exception

Throws:

Exception

testIncrementalAnalyzeUpdatedFile

public void testIncrementalAnalyzeUpdatedFile()
                                       throws Exception

Throws:

Exception

testIncrementalAnalyzeWithDifferentMetadataLevel

public void testIncrementalAnalyzeWithDifferentMetadataLevel()
                                                      throws Exception

Throws:

Exception

testDefaultSegment

public void testDefaultSegment()
                        throws Exception

Throws:

Exception

testAnalyzeWithMapColumns

public void testAnalyzeWithMapColumns()
                               throws Exception

Throws:

Exception

testDirPartitionPruning

public void testDirPartitionPruning()
                             throws Exception

Throws:

Exception

testPartitionPruningRootSegment

public void testPartitionPruningRootSegment()
                                     throws Exception

Throws:

Exception

testPartitionPruningVarCharPartition

public void testPartitionPruningVarCharPartition()
                                          throws Exception

Throws:

Exception

testPartitionPruningBinaryPartition

public void testPartitionPruningBinaryPartition()
                                         throws Exception

Throws:

Exception

testPartitionPruningSingleLeafPartition

public void testPartitionPruningSingleLeafPartition()
                                             throws Exception

Throws:

Exception

testPartitionPruningSingleNonLeafPartition

public void testPartitionPruningSingleNonLeafPartition()
                                                throws Exception

Throws:

Exception

testPartitionPruningDir1Filter

public void testPartitionPruningDir1Filter()
                                    throws Exception

Throws:

Exception

testPartitionPruningNonExistentPartition

public void testPartitionPruningNonExistentPartition()
                                              throws Exception

Throws:

Exception

testAnalyzeMultilevelTable

public void testAnalyzeMultilevelTable()
                                throws Exception

Throws:

Exception

testFieldWithDots

public void testFieldWithDots()
                       throws Exception

Throws:

Exception

testBooleanPartitionPruning

public void testBooleanPartitionPruning()
                                 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

testNonInterestingColumnInFilter

public void testNonInterestingColumnInFilter()
                                      throws Exception

Throws:

Exception

testSelectAfterAnalyzeWithNonRowGroupLevel

public void testSelectAfterAnalyzeWithNonRowGroupLevel()
                                                throws Exception

Throws:

Exception

testAnalyzeWithDisabledFallback

public void testAnalyzeWithDisabledFallback()
                                     throws Exception

Throws:

Exception

testAnalyzeWithSchemaError

public void testAnalyzeWithSchemaError()
                                throws Exception

Throws:

Exception

testAnalyzeWithSchema

public void testAnalyzeWithSchema()
                           throws Exception

Throws:

Exception

testUseStatistics

public void testUseStatistics()
                       throws Exception

Throws:

Exception

testAnalyzeWithDisabledStatistics

public void testAnalyzeWithDisabledStatistics()
                                       throws Exception

Throws:

Exception

testAnalyzeWithoutStatisticsWithStatsFile

public void testAnalyzeWithoutStatisticsWithStatsFile()
                                               throws Exception

Throws:

Exception

testAnalyzeWithSampleStatistics

public void testAnalyzeWithSampleStatistics()
                                     throws Exception

Throws:

Exception

testDropMetadata

public void testDropMetadata()
                      throws Exception

Throws:

Exception

testDropNonExistingMetadata

public void testDropNonExistingMetadata()
                                 throws Exception

Throws:

Exception

testIncorrectAnalyzeCommand

public void testIncorrectAnalyzeCommand()
                                 throws Exception

Throws:

Exception

testIncompleteAnalyzeCommand

public void testIncompleteAnalyzeCommand()
                                  throws Exception

Throws:

Exception

testAnalyzeOnView

public void testAnalyzeOnView()
                       throws Exception

Throws:

Exception

testSelectWithOutdatedMetadataWithUpdatedFile

public void testSelectWithOutdatedMetadataWithUpdatedFile()
                                                   throws Exception

Throws:

Exception

testSelectWithOutdatedMetadataWithNewFile

public void testSelectWithOutdatedMetadataWithNewFile()
                                               throws Exception

Throws:

Exception

testDescribeWithMetastore

public void testDescribeWithMetastore()
                               throws Exception

Throws:

Exception

testSelectFromInfoSchemaTablesWithMetastore

public void testSelectFromInfoSchemaTablesWithMetastore()
                                                 throws Exception

Throws:

Exception

testSelectFromInfoSchemaColumnsWithMetastore

public void testSelectFromInfoSchemaColumnsWithMetastore()
                                                  throws Exception

Throws:

Exception

testSelectFromInfoSchemaPartitionsWithMetastore

public void testSelectFromInfoSchemaPartitionsWithMetastore()
                                                     throws Exception

Throws:

Exception

testAnalyzeWithLeadingSlash

public void testAnalyzeWithLeadingSlash()
                                 throws Exception

Throws:

Exception

testAnalyzeEmptyNullableParquetTable

public void testAnalyzeEmptyNullableParquetTable()
                                          throws Exception

Throws:

Exception

testAnalyzeEmptyRequiredParquetTable

public void testAnalyzeEmptyRequiredParquetTable()
                                          throws Exception

Throws:

Exception

testAnalyzeNonEmptyTableWithEmptyFile

public void testAnalyzeNonEmptyTableWithEmptyFile()
                                           throws Exception

Throws:

Exception

testSelectEmptyRequiredParquetTable

public void testSelectEmptyRequiredParquetTable()
                                         throws Exception

Throws:

Exception

testSelectNonEmptyTableWithEmptyFile

public void testSelectNonEmptyTableWithEmptyFile()
                                          throws Exception

Throws:

Exception

testTableFunctionForParquet

public void testTableFunctionForParquet()
                                 throws Exception

Throws:

Exception

testTableFunctionWithDrop

public void testTableFunctionWithDrop()
                               throws Exception

Throws:

Exception

testAnalyzeWithClassPathSystem

public void testAnalyzeWithClassPathSystem()
                                    throws Exception

Throws:

Exception

testAnalyzeWithRootSchema

public void testAnalyzeWithRootSchema()
                               throws Exception

Throws:

Exception

testAnalyzeWithNonWritableWorkspace

public void testAnalyzeWithNonWritableWorkspace()
                                         throws Exception

Throws:

Exception

getColumnStatistics

public static <T> ColumnStatistics<T> getColumnStatistics(T minValue,
                                                          T maxValue,
                                                          long rowCount,
                                                          TypeProtos.MinorType minorType)

getBaseTableMetadata

public static BaseTableMetadata getBaseTableMetadata(TableInfo tableInfo,
                                                     File table,
                                                     TupleMetadata schema)

getBaseTableMetadata

public static BaseTableMetadata getBaseTableMetadata(TableInfo tableInfo,
                                                     File table)

getMaxLastModified

public static long getMaxLastModified(File file)

Returns last modification time for specified file or max last modification time of child files if specified one is a directory.

Parameters:

file - file whose last modification time should be returned

Returns:

last modification time