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

Class BaseMockBatchReader

java.lang.Object

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

All Implemented Interfaces:

ManagedReader

Direct Known Subclasses:

BaseScanTest.MockEarlySchemaReader

public abstract class BaseMockBatchReader
extends Object
implements ManagedReader

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.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.physical.impl.scan.v3.ManagedReader

ManagedReader.EarlyEofException

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
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.v3.ManagedReader

next

Field Detail

closeCalled

public boolean closeCalled

startIndex

public int startIndex

batchCount

public int batchCount

batchLimit

public int batchLimit

tableLoader

protected ResultSetLoader tableLoader

Constructor Detail

BaseMockBatchReader

public 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