Class JoinStatus
java.lang.Object
org.apache.drill.exec.physical.impl.join.JoinStatus
Maintain join state.
-
Field Summary
-
Constructor Summary
ConstructorDescriptionJoinStatus
(RecordIterator left, RecordIterator right, MergeJoinBatch output) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
Return state of join based on status of left and right iterator.final int
final void
void
boolean
final boolean
void
prepare()
final void
void
setHasMoreData
(boolean hasMoreData) final void
setTargetOutputRowCount
(int outputRowCount) boolean
toString()
-
Field Details
-
left
-
right
-
outputBatch
-
ok
public boolean ok -
hasMoreData
public boolean hasMoreData
-
-
Constructor Details
-
JoinStatus
-
-
Method Details
-
toString
-
initialize
public void initialize() -
prepare
public void prepare() -
getLeftStatus
-
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
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.
-