org.apache.drill.exec.physical.impl.protocol

Class TestOperatorRecordBatch

java.lang.Object

org.apache.drill.test.BaseTest

org.apache.drill.test.DrillTest

org.apache.drill.test.SubOperatorTest

org.apache.drill.exec.physical.impl.protocol.TestOperatorRecordBatch

public class TestOperatorRecordBatch
extends SubOperatorTest

Test the implementation of the Drill Volcano iterator protocol that wraps the modular operator implementation.

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

Method Summary

Modifier and Type	Method and Description
void	testBatchAccessor() The record batch abstraction has a bunch of methods to work with a vector container.
void	testFailAfterClose() Simulate the caller failing the operator after close.
void	testFailBeforeClose() Simulate the caller failing the operator after EOF but before close.
void	testFailEarly() Simulate the caller failing the operator before getting the schema.
void	testFailWhileReading() Simulate the caller failing the operator before EOF.
void	testFirstBatchEOF() Simulate reaching EOF on the first batch.
void	testNormalLifeCycle() Simulate a normal run: return some batches, encounter a schema change.
void	testSchemaChange()
void	testSchemaEOF() Simulate reaching EOF when trying to create the schema.
void	testSv2() Test that an SV2 is properly handled by the proper container accessor.
void	testTruncatedLifeCycle() Simulate a truncated life cycle: next() is never called.
void	testUserExceptionOnBind()
void	testUserExceptionOnBuildSchema()
void	testUserExceptionOnClose()
void	testUserExceptionOnNext()
void	testWrappedExceptionOnBind() Failure on the bind method.
void	testWrappedExceptionOnBuildSchema() Failure when building the schema (first call to next()).
void	testWrappedExceptionOnClose() Failure when closing the operator implementation.
void	testWrappedExceptionOnNext() Failure on the second or subsequent calls to next(), when actually fetching a record batch.

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

TestOperatorRecordBatch

public TestOperatorRecordBatch()

Method Detail

testNormalLifeCycle

public void testNormalLifeCycle()

Simulate a normal run: return some batches, encounter a schema change.

testTruncatedLifeCycle

public void testTruncatedLifeCycle()

Simulate a truncated life cycle: next() is never called. Not a valid part of the protocol; but should be ready anyway.

testSchemaEOF

public void testSchemaEOF()

Simulate reaching EOF when trying to create the schema.

testFirstBatchEOF

public void testFirstBatchEOF()

Simulate reaching EOF on the first batch. This simulated data source discovered a schema, but had no data.

testFailEarly

public void testFailEarly()

Simulate the caller failing the operator before getting the schema.

testFailWhileReading

public void testFailWhileReading()

Simulate the caller failing the operator before EOF.

testFailBeforeClose

public void testFailBeforeClose()

Simulate the caller failing the operator after EOF but before close. This is a silly time to fail, but have to handle it anyway.

testFailAfterClose

public void testFailAfterClose()

Simulate the caller failing the operator after close. This is violates the operator protocol, but have to handle it anyway.

testBatchAccessor

public void testBatchAccessor()

The record batch abstraction has a bunch of methods to work with a vector container. Rather than simply exposing the container itself, the batch instead exposes various container operations. Probably an artifact of its history. In any event, make sure those methods are passed through to the container accessor.

testSchemaChange

public void testSchemaChange()

testSv2

public void testSv2()

Test that an SV2 is properly handled by the proper container accessor.

testWrappedExceptionOnBind

public void testWrappedExceptionOnBind()

Failure on the bind method.

testUserExceptionOnBind

public void testUserExceptionOnBind()

testWrappedExceptionOnBuildSchema

public void testWrappedExceptionOnBuildSchema()

Failure when building the schema (first call to next()).

testUserExceptionOnBuildSchema

public void testUserExceptionOnBuildSchema()

testWrappedExceptionOnNext

public void testWrappedExceptionOnNext()

Failure on the second or subsequent calls to next(), when actually fetching a record batch.

testUserExceptionOnNext

public void testUserExceptionOnNext()

testWrappedExceptionOnClose

public void testWrappedExceptionOnClose()

Failure when closing the operator implementation.

testUserExceptionOnClose

public void testUserExceptionOnClose()