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

Class HashJoinBatch.HashJoinSpilledPartition

java.lang.Object

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

org.apache.drill.exec.physical.impl.join.HashJoinBatch.HashJoinSpilledPartition

All Implemented Interfaces:

SpilledPartitionMetadata

Enclosing class:

HashJoinBatch

public static class HashJoinBatch.HashJoinSpilledPartition
extends AbstractSpilledPartitionMetadata

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

HashJoinSpilledPartition

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

Method Detail

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()