Package org.apache.drill.exec.record

Class JoinBatchMemoryManager

java.lang.Object

org.apache.drill.exec.record.RecordBatchMemoryManager

org.apache.drill.exec.record.JoinBatchMemoryManager

public class JoinBatchMemoryManager
extends RecordBatchMemoryManager

Field Summary

Fields

Modifier and Type	Field	Description
static final int	LEFT_INDEX
static final int	RIGHT_INDEX

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

DEFAULT_INPUT_INDEX, MAX_NUM_ROWS, MIN_NUM_ROWS

Constructor Summary

Constructors

Constructor	Description
JoinBatchMemoryManager(int outputBatchSize, RecordBatch leftBatch, RecordBatch rightBatch, Set<String> excludedColumns)

Method Summary

Modifier and Type	Method	Description
void	update(int inputIndex, int outputPosition)	Update the memory manager parameters based on the new incoming batch (based on allocated sizes, not average row size)
void	update(int inputIndex, int outputPosition, boolean useAggregate)	Update the memory manager parameters based on the new incoming batch
void	update(RecordBatch batch, int inputIndex, int outputPosition)	Update the memory manager parameters based on the given (incoming) batch (based on allocated sizes, not average row size)
void	update(RecordBatch batch, int inputIndex, int outputPosition, boolean useAggregate)	Update the memory manager parameters based on the given (incoming) batch

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

adjustOutputRowCount, allocateVectors, allocateVectors, allocateVectors, allocateVectors, computeOutputRowCount, getAvgInputBatchSize, getAvgInputBatchSize, getAvgInputRowWidth, getAvgInputRowWidth, getAvgOutputBatchSize, getAvgOutputRowWidth, getColumnSize, getColumnSize, getCurrentOutgoingMaxRowCount, getNumIncomingBatches, getNumIncomingBatches, getNumOutgoingBatches, getOffsetVectorWidth, getOutgoingRowWidth, getOutputBatchSize, getOutputRowCount, getRecordBatchSizer, getRecordBatchSizer, getTotalInputRecords, getTotalInputRecords, getTotalOutputRecords, setCurrentOutgoingMaxRowCount, setOutgoingRowWidth, setOutputRowCount, setOutputRowCount, setRecordBatchSizer, setRecordBatchSizer, update, update, update, update, updateIfNeeded, updateIncomingStats, updateIncomingStats, updateOutgoingStats

Methods inherited from class java.lang.Object

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

Field Details

LEFT_INDEX

public static final int LEFT_INDEX

See Also:

• Constant Field Values

RIGHT_INDEX

public static final int RIGHT_INDEX

See Also:

• Constant Field Values

Constructor Details

JoinBatchMemoryManager

public JoinBatchMemoryManager(int outputBatchSize,
 RecordBatch leftBatch,
 RecordBatch rightBatch,
 Set<String> excludedColumns)

Method Details

update

public void update(int inputIndex,
 int outputPosition,
 boolean useAggregate)

Update the memory manager parameters based on the new incoming batch

Overrides:

update in class RecordBatchMemoryManager

Parameters:

inputIndex - Left (0) or Right (1)

outputPosition - Position (i.e. number of inserted rows) in the output batch

useAggregate - Compute using average row width (else based on allocated sizes)

update

public void update(int inputIndex,
 int outputPosition)

Update the memory manager parameters based on the new incoming batch (based on allocated sizes, not average row size)

Overrides:

update in class RecordBatchMemoryManager

Parameters:

inputIndex - Left (0) or Right (1)

outputPosition - Position (i.e. number of inserted rows) in the output batch

update

public void update(RecordBatch batch,
 int inputIndex,
 int outputPosition,
 boolean useAggregate)

Update the memory manager parameters based on the given (incoming) batch

Overrides:

update in class RecordBatchMemoryManager

Parameters:

batch - Update based on the data in this batch

inputIndex - Left (0) or Right (1)

outputPosition - Position (i.e. number of inserted rows) in the output batch

useAggregate - Compute using average row width (else based on allocated sizes)

update

public void update(RecordBatch batch,
 int inputIndex,
 int outputPosition)

Update the memory manager parameters based on the given (incoming) batch (based on allocated sizes, not average row size)

Overrides:

update in class RecordBatchMemoryManager

Parameters:

batch - Update based on the data in this batch

inputIndex - Left (0) or Right (1)

outputPosition - Position (i.e. number of inserted rows) in the output batch