org.apache.drill.exec.physical.impl

Class MockRecordBatch.Builder

java.lang.Object

org.apache.drill.exec.physical.impl.MockRecordBatch.Builder

Enclosing class:

MockRecordBatch

public static class MockRecordBatch.Builder
extends Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
MockRecordBatch	build(FragmentContext context)
MockRecordBatch.Builder	sendData(RowSet rowSet)
MockRecordBatch.Builder	sendDataAndEmit(RowSet rowSet)
MockRecordBatch.Builder	sendDataWithNewSchema(RowSet rowSet)
MockRecordBatch.Builder	setSchema(BatchSchema batchSchema)
MockRecordBatch.Builder	terminateWithError(RecordBatch.IterOutcome errorOutcome)
MockRecordBatch.Builder	withOperatorContext(OperatorContext oContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

sendData

public MockRecordBatch.Builder sendData(RowSet rowSet)

sendDataWithNewSchema

public MockRecordBatch.Builder sendDataWithNewSchema(RowSet rowSet)

sendDataAndEmit

public MockRecordBatch.Builder sendDataAndEmit(RowSet rowSet)

terminateWithError

public MockRecordBatch.Builder terminateWithError(RecordBatch.IterOutcome errorOutcome)

setSchema

public MockRecordBatch.Builder setSchema(BatchSchema batchSchema)

withOperatorContext

public MockRecordBatch.Builder withOperatorContext(OperatorContext oContext)

build

public MockRecordBatch build(FragmentContext context)