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

Class BaseScanTest

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

Direct Known Subclasses:

TestFixedReceiver, TestScanBasics, TestScanEarlySchema, TestScanLateSchema, TestScanOuputSchema, TestScanOverflow

public class BaseScanTest
extends SubOperatorTest

Test of the scan operator framework. Here the focus is on the implementation of the scan operator itself. This operator is based on a number of lower-level abstractions, each of which has its own unit tests. To make this more concrete: review the scan operator code paths. Each path should be exercised by one or more of the tests here. If, however, the code path depends on the details of another, supporting class, then tests for that class appear elsewhere.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BaseScanTest.BaseScanFixtureBuilder
protected static class	BaseScanTest.EofOnOpenReader Mock reader that returns no schema and no records.
protected static class	BaseScanTest.MockEarlySchemaReader Mock reader that pretends to have a schema at open time like an HBase or JDBC reader.
protected static class	BaseScanTest.ObservableCreator Fixture that creates the reader and gives a test access to the reader.
static interface	BaseScanTest.ReaderCreator Fixture that creates the reader and gives a test access to the reader.
static class	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
BaseScanTest()

Method Summary

Modifier and Type	Method and Description
protected TupleMetadata	expectedSchema()
protected RowSet.SingleRowSet	makeExpected()
protected RowSet.SingleRowSet	makeExpected(int offset)
static BaseScanTest.BaseScanFixtureBuilder	simpleBuilder(BaseScanTest.ReaderCreator... readers)
static ScanFixture	simpleFixture(BaseScanTest.ReaderCreator... readers)
protected void	verifyBatch(int offset, VectorContainer output)

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

BaseScanTest

public BaseScanTest()

Method Detail

expectedSchema

protected TupleMetadata expectedSchema()

makeExpected

protected RowSet.SingleRowSet makeExpected()

makeExpected

protected RowSet.SingleRowSet makeExpected(int offset)

verifyBatch

protected void verifyBatch(int offset,
                           VectorContainer output)

simpleBuilder

@SafeVarargs
public static BaseScanTest.BaseScanFixtureBuilder simpleBuilder(BaseScanTest.ReaderCreator... readers)

simpleFixture

@SafeVarargs
public static ScanFixture simpleFixture(BaseScanTest.ReaderCreator... readers)