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

Class TraceRecordBatch

java.lang.Object

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

org.apache.drill.exec.record.AbstractUnaryRecordBatch<T>

org.apache.drill.exec.record.AbstractSingleRecordBatch<Trace>

org.apache.drill.exec.physical.impl.trace.TraceRecordBatch

All Implemented Interfaces:

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

public class TraceRecordBatch
extends AbstractSingleRecordBatch<Trace>

Contains value vectors which are exactly the same as the incoming record batch's value vectors. If the incoming record batch has a selection vector (type 2) then TraceRecordBatch will also contain a selection vector.

Purpose of this record batch is to dump the data associated with all the value vectors and selection vector to disk.

This record batch does not modify any data or schema, it simply consumes the incoming record batch's data, dump to disk and pass the same set of value vectors (and selection vectors) to its parent record batch.

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.record.AbstractSingleRecordBatch

incoming

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

callBack

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
TraceRecordBatch(Trace pop, RecordBatch incoming, FragmentContext context)

Method Summary

Modifier and Type	Method	Description
void	close()
protected RecordBatch.IterOutcome	doWork()	Invoked for every record batch and it simply dumps the buffers associated with all the value vectors in this record batch to a log file.
void	dump()	Perform dump of this batch's state to logs.
int	getRecordCount()	Get the number of records.
SelectionVector2	getSelectionVector2()
protected boolean	setupNewSchema()

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

getFinalOutcome, getIncoming

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

cancelIncoming, getLastKnownOutcome, handleNullInput, innerNext, setLastKnownOutcome

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

buildSchema, cancel, checkContinue, getContainer, getContext, getOutgoingContainer, getPopConfig, getRecordBatchStatsContext, getSchema, 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

TraceRecordBatch

public TraceRecordBatch(Trace pop,
 RecordBatch incoming,
 FragmentContext context)
                 throws ExecutionSetupException

Throws:

ExecutionSetupException

Method Details

getRecordCount

public int getRecordCount()

Description copied from interface: VectorAccessible

Get the number of records.

Returns:

number of records

doWork

protected RecordBatch.IterOutcome doWork()

Invoked for every record batch and it simply dumps the buffers associated with all the value vectors in this record batch to a log file.

Specified by:

doWork in class AbstractUnaryRecordBatch<Trace>

setupNewSchema

protected boolean setupNewSchema()

Specified by:

setupNewSchema in class AbstractUnaryRecordBatch<Trace>

getSelectionVector2

public SelectionVector2 getSelectionVector2()

Specified by:

getSelectionVector2 in interface VectorAccessible

Overrides:

getSelectionVector2 in class AbstractRecordBatch<Trace>

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractRecordBatch<Trace>

dump

public void dump()

Description copied from interface: RecordBatch

Perform dump of this batch's state to logs.