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

Class BaseScanOperatorExecTest

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

Direct Known Subclasses:

TestScanOperExecBasics, TestScanOperExecEarlySchema, TestScanOperExecLateSchema, TestScanOperExecOuputSchema, TestScanOperExecOverflow, TestScanOperExecSmoothing

public class BaseScanOperatorExecTest
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
protected static class	BaseScanOperatorExecTest.BaseMockBatchReader Base class for the "mock" readers used in this test.
static class	BaseScanOperatorExecTest.BaseScanFixtureBuilder
protected static class	BaseScanOperatorExecTest.MockEarlySchemaReader Mock reader that pretends to have a schema at open time like an HBase or JDBC reader.

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

Method Summary

Modifier and Type	Method and Description
protected TupleMetadata	expectedSchema()
protected RowSet.SingleRowSet	makeExpected()
protected RowSet.SingleRowSet	makeExpected(int offset)
static BaseScanOperatorExecTest.BaseScanFixtureBuilder	simpleBuilder(ManagedReader<SchemaNegotiator>... readers)
static ScanTestUtils.ScanFixture	simpleFixture(ManagedReader<SchemaNegotiator>... 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

BaseScanOperatorExecTest

public BaseScanOperatorExecTest()

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 BaseScanOperatorExecTest.BaseScanFixtureBuilder simpleBuilder(ManagedReader<SchemaNegotiator>... readers)

simpleFixture

@SafeVarargs
public static ScanTestUtils.ScanFixture simpleFixture(ManagedReader<SchemaNegotiator>... readers)