org.apache.drill.exec.store.avro

Class AvroFormatTest

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.ClusterTest

org.apache.drill.exec.store.avro.AvroFormatTest

public class AvroFormatTest
extends ClusterTest

Unit tests for Avro record reader.

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

Method Summary

Modifier and Type	Method and Description
static void	setup()
void	testArrayMapSchemaElementGetByKey()
void	testArrayMapSchemaGetElementByIndex()
void	testCountStar()
void	testDateTime()
void	testDecimal()
void	testDoubleNestedSchema_NoNullValues_NotAllColumnsProjected()
void	testDoubleNestedSchema_NoNullValues()
void	testDoubleNestedSchema_StarQuery()
void	testDuration()
void	testFlattenComplexArray()
void	testFlattenEmptyComplexArrayMustYieldNoResults()
void	testFlattenPrimitiveArray()
void	testImplicitColumnAlone()
void	testImplicitColumnInWhereClause()
void	testImplicitColumnsWithStar()
void	testLinkedList()
void	testMapArraySchema()
void	testMapSchema_withNullValues()
void	testMapSchema()
void	testMapSchemaArrayValue()
void	testMapSchemaArrayValueGetByKey()
void	testMapSchemaArrayValueGetByKeyElementByIndex()
void	testMapSchemaComplex_withNullValues()
void	testMapSchemaGetByKey()
void	testMapSchemaGetByKeyUsingDotNotation()
void	testMapSchemaGetByNotExistingKey()
void	testMapSchemaValueInFilter()
void	testMapSchemaValueInFilter2()
void	testMultiDimensionalArray()
void	testNestedUnionArraySchema_withNullValues()
void	testNestedUnionSchema_withNullValues()
void	testPartitionColumn()
void	testShouldFailSimpleUnionNonNullSchema_StarQuery()
void	testSimpleArraySchema_NoNullValues()
void	testSimpleArraySchema_StarQuery()
void	testSimpleEnumSchema_NoNullValues()
void	testSimpleEnumSchema_StarQuery()
void	testSimpleNestedSchema_NoNullValues()
void	testSimpleNestedSchema_StarQuery()
void	testSimplePrimitiveSchema_NoNullValues()
void	testSimplePrimitiveSchema_SelectColumnSubset()
void	testSimplePrimitiveSchema_StarQuery()
void	testSimpleUnionSchema_StarQuery()
void	testStringAndUtf8Data()
void	testWithProvidedSchema()

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

thrown

public org.junit.rules.ExpectedException thrown

Constructor Detail

AvroFormatTest

public AvroFormatTest()

Method Detail

setup

public static void setup()
                  throws Exception

Throws:

Exception

testSimplePrimitiveSchema_NoNullValues

public void testSimplePrimitiveSchema_NoNullValues()
                                            throws Exception

Throws:

Exception

testSimplePrimitiveSchema_StarQuery

public void testSimplePrimitiveSchema_StarQuery()
                                         throws Exception

Throws:

Exception

testSimplePrimitiveSchema_SelectColumnSubset

public void testSimplePrimitiveSchema_SelectColumnSubset()
                                                  throws Exception

Throws:

Exception

testImplicitColumnsWithStar

public void testImplicitColumnsWithStar()
                                 throws Exception

Throws:

Exception

testImplicitColumnAlone

public void testImplicitColumnAlone()
                             throws Exception

Throws:

Exception

testImplicitColumnInWhereClause

public void testImplicitColumnInWhereClause()
                                     throws Exception

Throws:

Exception

testPartitionColumn

public void testPartitionColumn()
                         throws Exception

Throws:

Exception

testSimpleArraySchema_NoNullValues

public void testSimpleArraySchema_NoNullValues()
                                        throws Exception

Throws:

Exception

testSimpleArraySchema_StarQuery

public void testSimpleArraySchema_StarQuery()
                                     throws Exception

Throws:

Exception

testDoubleNestedSchema_NoNullValues_NotAllColumnsProjected

public void testDoubleNestedSchema_NoNullValues_NotAllColumnsProjected()
                                                                throws Exception

Throws:

Exception

testSimpleNestedSchema_NoNullValues

public void testSimpleNestedSchema_NoNullValues()
                                         throws Exception

Throws:

Exception

testSimpleNestedSchema_StarQuery

public void testSimpleNestedSchema_StarQuery()
                                      throws Exception

Throws:

Exception

testDoubleNestedSchema_NoNullValues

public void testDoubleNestedSchema_NoNullValues()
                                         throws Exception

Throws:

Exception

testDoubleNestedSchema_StarQuery

public void testDoubleNestedSchema_StarQuery()
                                      throws Exception

Throws:

Exception

testSimpleEnumSchema_NoNullValues

public void testSimpleEnumSchema_NoNullValues()
                                       throws Exception

Throws:

Exception

testSimpleEnumSchema_StarQuery

public void testSimpleEnumSchema_StarQuery()
                                    throws Exception

Throws:

Exception

testSimpleUnionSchema_StarQuery

public void testSimpleUnionSchema_StarQuery()
                                     throws Exception

Throws:

Exception

testShouldFailSimpleUnionNonNullSchema_StarQuery

public void testShouldFailSimpleUnionNonNullSchema_StarQuery()
                                                      throws Exception

Throws:

Exception

testNestedUnionSchema_withNullValues

public void testNestedUnionSchema_withNullValues()
                                          throws Exception

Throws:

Exception

testFlattenPrimitiveArray

public void testFlattenPrimitiveArray()
                               throws Exception

Throws:

Exception

testFlattenComplexArray

public void testFlattenComplexArray()
                             throws Exception

Throws:

Exception

testFlattenEmptyComplexArrayMustYieldNoResults

public void testFlattenEmptyComplexArrayMustYieldNoResults()
                                                    throws Exception

Throws:

Exception

testNestedUnionArraySchema_withNullValues

public void testNestedUnionArraySchema_withNullValues()
                                               throws Exception

Throws:

Exception

testMapSchema_withNullValues

public void testMapSchema_withNullValues()
                                  throws Exception

Throws:

Exception

testMapSchemaComplex_withNullValues

public void testMapSchemaComplex_withNullValues()
                                         throws Exception

Throws:

Exception

testStringAndUtf8Data

public void testStringAndUtf8Data()
                           throws Exception

Throws:

Exception

testLinkedList

public void testLinkedList()
                    throws Exception

Throws:

Exception

testCountStar

public void testCountStar()
                   throws Exception

Throws:

Exception

testMapSchema

public void testMapSchema()
                   throws Exception

Throws:

Exception

testMapSchemaGetByKey

public void testMapSchemaGetByKey()
                           throws Exception

Throws:

Exception

testMapSchemaGetByNotExistingKey

public void testMapSchemaGetByNotExistingKey()
                                      throws Exception

Throws:

Exception

testMapSchemaGetByKeyUsingDotNotation

public void testMapSchemaGetByKeyUsingDotNotation()
                                           throws Exception

Throws:

Exception

testMapArraySchema

public void testMapArraySchema()
                        throws Exception

Throws:

Exception

testArrayMapSchemaGetElementByIndex

public void testArrayMapSchemaGetElementByIndex()
                                         throws Exception

Throws:

Exception

testArrayMapSchemaElementGetByKey

public void testArrayMapSchemaElementGetByKey()
                                       throws Exception

Throws:

Exception

testMapSchemaArrayValue

public void testMapSchemaArrayValue()
                             throws Exception

Throws:

Exception

testMapSchemaArrayValueGetByKey

public void testMapSchemaArrayValueGetByKey()
                                     throws Exception

Throws:

Exception

testMapSchemaArrayValueGetByKeyElementByIndex

public void testMapSchemaArrayValueGetByKeyElementByIndex()
                                                   throws Exception

Throws:

Exception

testMapSchemaValueInFilter

public void testMapSchemaValueInFilter()
                                throws Exception

Throws:

Exception

testMapSchemaValueInFilter2

public void testMapSchemaValueInFilter2()
                                 throws Exception

Throws:

Exception

testDecimal

public void testDecimal()
                 throws Exception

Throws:

Exception

testDateTime

public void testDateTime()
                  throws Exception

Throws:

Exception

testDuration

public void testDuration()
                  throws Exception

Throws:

Exception

testMultiDimensionalArray

public void testMultiDimensionalArray()
                               throws Exception

Throws:

Exception

testWithProvidedSchema

public void testWithProvidedSchema()
                            throws Exception

Throws:

Exception