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

Class BaseTestScanLifecycle.MockEarlySchemaReader

java.lang.Object

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

org.apache.drill.exec.physical.impl.scan.v3.lifecycle.BaseTestScanLifecycle.MockEarlySchemaReader

All Implemented Interfaces:

ManagedReader

Enclosing class:

BaseTestScanLifecycle

protected static class BaseTestScanLifecycle.MockEarlySchemaReader
extends BaseTestScanLifecycle.BaseMockBatchReader

"Early schema" refers to the case in which the reader can provide a schema when the reader is opened. Examples: CSV, HBase, MapR-DB binary, JDBC.

Nested Class Summary

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

ManagedReader.EarlyEofException

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.scan.v3.lifecycle.BaseTestScanLifecycle.BaseMockBatchReader

batchCount, batchLimit, startIndex, tableLoader

Constructor Summary

Constructors

Constructor and Description
MockEarlySchemaReader(SchemaNegotiator negotiator, int batchCount)

Method Summary

Methods inherited from class org.apache.drill.exec.physical.impl.scan.v3.lifecycle.BaseTestScanLifecycle.BaseMockBatchReader

close, makeBatch, next

Methods inherited from class java.lang.Object

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

Constructor Detail

MockEarlySchemaReader

public MockEarlySchemaReader(SchemaNegotiator negotiator,
                             int batchCount)