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

Class BaseScanOperatorExecTest.BaseMockBatchReader

java.lang.Object

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

All Implemented Interfaces:

ManagedReader<SchemaNegotiator>

Direct Known Subclasses:

BaseScanOperatorExecTest.MockEarlySchemaReader

Enclosing class:

BaseScanOperatorExecTest

protected abstract static class BaseScanOperatorExecTest.BaseMockBatchReader
extends Object
implements ManagedReader<SchemaNegotiator>

Base class for the "mock" readers used in this test. The mock readers follow the normal (enhanced) reader API, but instead of actually reading from a data source, they just generate data with a known schema. They also expose internal state such as identifying which methods were actually called.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	batchCount
protected int	batchLimit
protected boolean	closeCalled
protected boolean	openCalled
protected int	startIndex
protected ResultSetLoader	tableLoader

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseMockBatchReader()

Method Summary

Modifier and Type	Method and Description
void	close() Release resources.
protected void	makeBatch()
protected void	writeRow(RowSetLoader writer, int col1, String col2)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.drill.exec.physical.impl.scan.framework.ManagedReader

next, open

Field Detail

openCalled

protected boolean openCalled

closeCalled

protected boolean closeCalled

startIndex

protected int startIndex

batchCount

protected int batchCount

batchLimit

protected int batchLimit

tableLoader

protected ResultSetLoader tableLoader

Constructor Detail

BaseMockBatchReader

protected BaseMockBatchReader()

Method Detail

makeBatch

protected void makeBatch()

writeRow

protected void writeRow(RowSetLoader writer,
                        int col1,
                        String col2)

close

public void close()

Description copied from interface: ManagedReader

Release resources. Called just after a failure, when the scanner is cancelled, or after next() returns EOF. Release all resources and close files. Guaranteed to be called if open() returns normally; will not be called if open() throws an exception.

Specified by:

close in interface ManagedReader<SchemaNegotiator>