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

Class JoinStatus

java.lang.Object

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

public final class JoinStatus
extends Object

Maintain join state.

Field Summary

Fields

Modifier and Type	Field	Description
boolean	hasMoreData
final RecordIterator	left
boolean	ok
MergeJoinBatch	outputBatch
final RecordIterator	right

Constructor Summary

Constructors

Constructor	Description
JoinStatus(RecordIterator left, RecordIterator right, MergeJoinBatch output)

Method Summary

Modifier and Type	Method	Description
void	disableMarking()
void	enableMarking()
RecordBatch.IterOutcome	getLeftStatus()
JoinWorker.JoinOutcome	getOutcome()	Return state of join based on status of left and right iterator.
final int	getOutPosition()
RecordBatch.IterOutcome	getRightStatus()
final void	incOutputPos()
void	initialize()
boolean	isHasMoreData()
final boolean	isOutgoingBatchFull()
void	prepare()
final void	resetOutputPos()
void	setHasMoreData(boolean hasMoreData)
final void	setTargetOutputRowCount(int outputRowCount)
boolean	shouldMark()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

left

public final RecordIterator left

right

public final RecordIterator right

outputBatch

public MergeJoinBatch outputBatch

ok

public boolean ok

hasMoreData

public boolean hasMoreData

Constructor Details

JoinStatus

public JoinStatus(RecordIterator left,
 RecordIterator right,
 MergeJoinBatch output)

Method Details

toString

public String toString()

Overrides:

toString in class Object

initialize

public void initialize()

prepare

public void prepare()

getLeftStatus

public RecordBatch.IterOutcome getLeftStatus()

getRightStatus

public RecordBatch.IterOutcome getRightStatus()

getOutPosition

public final int getOutPosition()

resetOutputPos

public final void resetOutputPos()

isOutgoingBatchFull

public final boolean isOutgoingBatchFull()

setTargetOutputRowCount

public final void setTargetOutputRowCount(int outputRowCount)

incOutputPos

public final void incOutputPos()

disableMarking

public void disableMarking()

enableMarking

public void enableMarking()

shouldMark

public boolean shouldMark()

isHasMoreData

public boolean isHasMoreData()

setHasMoreData

public void setHasMoreData(boolean hasMoreData)

getOutcome

public JoinWorker.JoinOutcome getOutcome()

Return state of join based on status of left and right iterator.

Returns:

1. JoinOutcome.NO_MORE_DATA : Join is finished 2. JoinOutcome.FAILURE : There is an error during join. 3. JoinOutcome.BATCH_RETURNED : one of the side has data 4. JoinOutcome.SCHEMA_CHANGED : one of the side has change in schema.