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

Class BufferedBatches

java.lang.Object

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

public class BufferedBatches
extends Object

Represents the set of in-memory batches accumulated by the external sort.

Constructor Summary

Constructors

Constructor	Description
BufferedBatches(OperatorContext opContext)

Method Summary

Modifier and Type	Method	Description
void	add(VectorAccessible incoming, long batchSize)
void	close()
List<BatchGroup>	prepareSpill(long targetSpillSize)
List<InputBatch>	removeAll()
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

BufferedBatches

public BufferedBatches(OperatorContext opContext)

Method Details

setSchema

public void setSchema(BatchSchema schema)

size

public int size()

add

public void add(VectorAccessible incoming,
 long batchSize)

prepareSpill

public List<BatchGroup> prepareSpill(long targetSpillSize)

removeAll

public List<InputBatch> removeAll()

close

public void close()