org.apache.drill.exec.physical.impl.scan.v3

Class TestScanEarlySchema

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.SubOperatorTest

org.apache.drill.exec.physical.impl.scan.v3.BaseScanTest

org.apache.drill.exec.physical.impl.scan.v3.TestScanEarlySchema

public class TestScanEarlySchema
extends BaseScanTest

Test "early schema" readers: those that can declare a schema at open time.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.physical.impl.scan.v3.BaseScanTest

BaseScanTest.BaseScanFixtureBuilder, BaseScanTest.EofOnOpenReader, BaseScanTest.MockEarlySchemaReader, BaseScanTest.ObservableCreator, BaseScanTest.ReaderCreator, BaseScanTest.ReaderFactoryFixture

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

DrillTest.MemWatcher

Field Summary

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

dirTestWatcher, fixture

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

logOutcome, objectMapper, REPEAT_RULE, thrownException, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
TestScanEarlySchema()

Method Summary

Modifier and Type	Method and Description
void	testEarlySchemaDataWithEof()
void	testEarlySchemaLifecycle()
void	testEarlySchemaLifecycleNoSchemaBatch()
void	testEOFOnFirstBatch()
void	testEOFOnSchema() Test EOF on the first batch.
void	testMultipleReaders() Test normal case with multiple readers.

Methods inherited from class org.apache.drill.exec.physical.impl.scan.v3.BaseScanTest

expectedSchema, makeExpected, makeExpected, simpleBuilder, simpleFixture, verifyBatch

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

classSetup, classTeardown

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

TestScanEarlySchema

public TestScanEarlySchema()

Method Detail

testEarlySchemaLifecycle

public void testEarlySchemaLifecycle()

testEarlySchemaLifecycleNoSchemaBatch

public void testEarlySchemaLifecycleNoSchemaBatch()

testEarlySchemaDataWithEof

public void testEarlySchemaDataWithEof()

testEOFOnSchema

public void testEOFOnSchema()

Test EOF on the first batch. Is allowed, but will result in the scan operator passing a null batch to the parent.

testEOFOnFirstBatch

public void testEOFOnFirstBatch()

testMultipleReaders

public void testMultipleReaders()

Test normal case with multiple readers. These return the same schema, so no schema change.