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

Class SpilledRuns

java.lang.Object

org.apache.drill.exec.physical.impl.xsort.SpilledRuns

public class SpilledRuns
extends Object

Represents the set of spilled batches, including methods to spill and/or merge a set of batches to produce a new spill file.

Constructor Summary

Constructors

Constructor	Description
SpilledRuns(OperatorContext opContext, SpillSet spillSet, PriorityQueueCopierWrapper copier)

Method Summary

Modifier and Type	Method	Description
void	close()
SortImpl.SortResults	finalMerge(List<? extends BatchGroup> bufferedBatches, VectorContainer container, int mergeRowCount, VectorInitializer allocHelper)
long	getWriteBytes()
boolean	hasSpilled()
void	mergeAndSpill(List<BatchGroup> batchesToSpill, int spillBatchRowCount, VectorInitializer allocHelper)
void	mergeRuns(int targetCount, long mergeMemoryPool, int spillBatchRowCount, VectorInitializer allocHelper)
static List<BatchGroup>	prepareSpillBatches(LinkedList<? extends BatchGroup> source, int spillCount)
void	setSchema(BatchSchema schema)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Details

SpilledRuns

public SpilledRuns(OperatorContext opContext,
 SpillSet spillSet,
 PriorityQueueCopierWrapper copier)

Method Details

setSchema

public void setSchema(BatchSchema schema)

size

public int size()

hasSpilled

public boolean hasSpilled()

getWriteBytes

public long getWriteBytes()

prepareSpillBatches

public static List<BatchGroup> prepareSpillBatches(LinkedList<? extends BatchGroup> source,
 int spillCount)

mergeAndSpill

public void mergeAndSpill(List<BatchGroup> batchesToSpill,
 int spillBatchRowCount,
 VectorInitializer allocHelper)

mergeRuns

public void mergeRuns(int targetCount,
 long mergeMemoryPool,
 int spillBatchRowCount,
 VectorInitializer allocHelper)

finalMerge

public SortImpl.SortResults finalMerge(List<? extends BatchGroup> bufferedBatches,
 VectorContainer container,
 int mergeRowCount,
 VectorInitializer allocHelper)

close

public void close()