Class JoinStatus

java.lang.Object
org.apache.drill.exec.physical.impl.join.JoinStatus

public final class JoinStatus extends Object
Maintain join state.
  • Field Details

  • Constructor Details

  • 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.