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

Class TestScanBasics

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.TestScanBasics

public class TestScanBasics
extends BaseScanTest

Tests the basics of the scan operator protocol: error conditions, etc.

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

Modifier and Type	Field and Description
static String	ERROR_MSG

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

Method Summary

Modifier and Type	Method and Description
void	testEarlyScanClose()
void	testEOFOnFirstOpen()
void	testExceptionOnClose()
void	testExceptionOnFirstNext()
void	testExceptionOnOpen()
void	testExceptionOnSecondNext() Test throwing an exception after the first batch, but while "reading" the second.
void	testMultiEOFOnFirstBatch() Test multiple readers, all EOF on first batch.
void	testNoReader() Pathological case that a scan operator is provided no readers.
void	testUserExceptionOnClose()
void	testUserExceptionOnFirstNext()
void	testUserExceptionOnOpen()
void	testUserExceptionOnSecondNext()

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

Field Detail

ERROR_MSG

public static final String ERROR_MSG

See Also:

Constant Field Values

Constructor Detail

TestScanBasics

public TestScanBasics()

Method Detail

testNoReader

public void testNoReader()

Pathological case that a scan operator is provided no readers. It will throw a user exception because the downstream operators can't handle this case so we choose to stop the show early to avoid getting into a strange state.

testExceptionOnOpen

public void testExceptionOnOpen()

testUserExceptionOnOpen

public void testUserExceptionOnOpen()

testExceptionOnFirstNext

public void testExceptionOnFirstNext()

testUserExceptionOnFirstNext

public void testUserExceptionOnFirstNext()

testExceptionOnSecondNext

public void testExceptionOnSecondNext()

Test throwing an exception after the first batch, but while "reading" the second. Note that the first batch returns data and is spread over two next() calls, so the error is on the third call to the scan operator next().

testUserExceptionOnSecondNext

public void testUserExceptionOnSecondNext()

testExceptionOnClose

public void testExceptionOnClose()

testUserExceptionOnClose

public void testUserExceptionOnClose()

testEOFOnFirstOpen

public void testEOFOnFirstOpen()

testMultiEOFOnFirstBatch

public void testMultiEOFOnFirstBatch()

Test multiple readers, all EOF on first batch. The scan will return one empty batch to declare the early schema. Results in an empty (rather than null) result set.

testEarlyScanClose

public void testEarlyScanClose()