Package org.apache.drill.exec.physical.impl

Class InsertWriterRecordBatch

java.lang.Object

org.apache.drill.exec.record.AbstractRecordBatch<Writer>

org.apache.drill.exec.physical.impl.WriterRecordBatch

org.apache.drill.exec.physical.impl.InsertWriterRecordBatch

All Implemented Interfaces:

AutoCloseable, Iterable<VectorWrapper<?>>, CloseableRecordBatch, RecordBatch, VectorAccessible

public class InsertWriterRecordBatch
extends WriterRecordBatch

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.record.AbstractRecordBatch

AbstractRecordBatch.BatchState

Nested classes/interfaces inherited from interface org.apache.drill.exec.record.RecordBatch

RecordBatch.IterOutcome

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.WriterRecordBatch

counter

Fields inherited from class org.apache.drill.exec.record.AbstractRecordBatch

batchStatsContext, container, context, oContext, popConfig, state, stats, unionTypeEnabled

Fields inherited from interface org.apache.drill.exec.record.RecordBatch

MAX_BATCH_ROW_COUNT

Constructor Summary

Constructors

Constructor	Description
InsertWriterRecordBatch(Writer writer, RecordBatch incoming, FragmentContext context, RecordWriter recordWriter)

Method Summary

Modifier and Type	Method	Description
protected void	addOutputContainerData()
protected void	addOutputSchema()

Methods inherited from class org.apache.drill.exec.physical.impl.WriterRecordBatch

cancelIncoming, close, dump, getRecordCount, getSchema, innerNext, setupNewSchema

Methods inherited from class org.apache.drill.exec.record.AbstractRecordBatch

buildSchema, cancel, checkContinue, getContainer, getContext, getOutgoingContainer, getPopConfig, getRecordBatchStatsContext, getSelectionVector2, getSelectionVector4, getValueAccessorById, getValueVectorId, getWritableBatch, isRecordBatchStatsLoggingEnabled, iterator, next, next, next, schemaChangeException, schemaChangeException

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

InsertWriterRecordBatch

public InsertWriterRecordBatch(Writer writer,
 RecordBatch incoming,
 FragmentContext context,
 RecordWriter recordWriter)
                        throws OutOfMemoryException

Throws:

OutOfMemoryException

Method Details

addOutputContainerData

protected void addOutputContainerData()

Overrides:

addOutputContainerData in class WriterRecordBatch

addOutputSchema

protected void addOutputSchema()

Overrides:

addOutputSchema in class WriterRecordBatch