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

Class AbstractHashBinaryRecordBatch.SpilledPartition

java.lang.Object

org.apache.drill.exec.physical.impl.common.AbstractSpilledPartitionMetadata

org.apache.drill.exec.physical.impl.join.AbstractHashBinaryRecordBatch.SpilledPartition

All Implemented Interfaces:

SpilledPartitionMetadata

Enclosing class:

AbstractHashBinaryRecordBatch<T extends PhysicalOperator>

public static class AbstractHashBinaryRecordBatch.SpilledPartition
extends AbstractSpilledPartitionMetadata

This holds information about the spilled partitions for the build and probe side.

Constructor Summary

Constructors

Constructor	Description
SpilledPartition(int cycle, int originPartition, int prevOriginPartition, int innerSpilledBatches, String innerSpillFile)

Method Summary

Modifier and Type	Method	Description
int	getInnerSpilledBatches()
String	getInnerSpillFile()
int	getOuterSpilledBatches()
String	getOuterSpillFile()
String	makeDebugString()
void	updateOuter(int outerSpilledBatches, String outerSpillFile)

Methods inherited from class org.apache.drill.exec.physical.impl.common.AbstractSpilledPartitionMetadata

getCycle, getOriginPartition, getPrevOriginPartition

Methods inherited from class java.lang.Object

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

Constructor Details

SpilledPartition

public SpilledPartition(int cycle,
 int originPartition,
 int prevOriginPartition,
 int innerSpilledBatches,
 String innerSpillFile)

Method Details

getInnerSpilledBatches

public int getInnerSpilledBatches()

getInnerSpillFile

public String getInnerSpillFile()

getOuterSpilledBatches

public int getOuterSpilledBatches()

getOuterSpillFile

public String getOuterSpillFile()

updateOuter

public void updateOuter(int outerSpilledBatches,
 String outerSpillFile)

makeDebugString

public String makeDebugString()