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

Class HashAggTemplate.BatchHolder

java.lang.Object

org.apache.drill.exec.physical.impl.aggregate.HashAggTemplate.BatchHolder

Enclosing class:

HashAggTemplate

public class HashAggTemplate.BatchHolder
extends Object

Constructor Summary

Constructors

Constructor	Description
BatchHolder(int batchRowCount)

Method Summary

Modifier and Type	Method	Description
int	getCurrentRowCount()
int	getTargetBatchRowCount()
void	outputRecordValues(int htRowIdx, int outRowIdx)
void	setTargetBatchRowCount(int batchRowCount)
void	setupInterior(RecordBatch incoming, RecordBatch outgoing, VectorContainer aggrValuesContainer)
void	updateAggrValuesInternal(int incomingRowIdx, int htRowIdx)

Methods inherited from class java.lang.Object

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

Constructor Details

BatchHolder

public BatchHolder(int batchRowCount)

Method Details

getTargetBatchRowCount

public int getTargetBatchRowCount()

setTargetBatchRowCount

public void setTargetBatchRowCount(int batchRowCount)

getCurrentRowCount

public int getCurrentRowCount()

setupInterior

public void setupInterior(@Named("incoming")
 RecordBatch incoming,
 @Named("outgoing")
 RecordBatch outgoing,
 @Named("aggrValuesContainer")
 VectorContainer aggrValuesContainer)
                   throws SchemaChangeException

Throws:

SchemaChangeException

updateAggrValuesInternal

public void updateAggrValuesInternal(@Named("incomingRowIdx")
 int incomingRowIdx,
 @Named("htRowIdx")
 int htRowIdx)
                              throws SchemaChangeException

Throws:

SchemaChangeException

outputRecordValues

public void outputRecordValues(@Named("htRowIdx")
 int htRowIdx,
 @Named("outRowIdx")
 int outRowIdx)
                        throws SchemaChangeException

Throws:

SchemaChangeException