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

Class BaseScanTest.ObservableCreator

java.lang.Object

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

All Implemented Interfaces:

BaseScanTest.ReaderCreator

Enclosing class:

BaseScanTest

protected abstract static class BaseScanTest.ObservableCreator
extends Object
implements BaseScanTest.ReaderCreator

Fixture that creates the reader and gives a test access to the reader.

Field Summary

Fields

Modifier and Type	Field and Description
ManagedReader	reader

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ObservableCreator()

Method Summary

Modifier and Type	Method and Description
abstract ManagedReader	create(SchemaNegotiator negotiator)
ManagedReader	instance(SchemaNegotiator negotiator)
<T extends ManagedReader> T	reader()

Methods inherited from class java.lang.Object

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

Field Detail

reader

public ManagedReader reader

Constructor Detail

ObservableCreator

protected ObservableCreator()

Method Detail

instance

public ManagedReader instance(SchemaNegotiator negotiator)
                       throws ManagedReader.EarlyEofException

Specified by:

instance in interface BaseScanTest.ReaderCreator

Throws:

ManagedReader.EarlyEofException

reader

public <T extends ManagedReader> T reader()

create

public abstract ManagedReader create(SchemaNegotiator negotiator)
                              throws ManagedReader.EarlyEofException

Throws:

ManagedReader.EarlyEofException