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

Interface RowKeyJoin

All Known Implementing Classes:
HashJoinBatch, RowKeyJoinBatch
public interface RowKeyJoin
Interface for a row key join

  • Method Details

    • hasRowKeyBatch

      boolean hasRowKeyBatch()
      Is the next batch of row keys ready to be returned
      Returns:
      True if ready, false if not

    • nextRowKeyBatch

      org.apache.commons.lang3.tuple.Pair<ValueVector,Integer> nextRowKeyBatch()
      Get the next batch of row keys
      Returns:
      a Pair whose left element is the ValueVector containing the row keys, right element is the number of row keys in this batch

    • getBatchState

      AbstractRecordBatch.BatchState getBatchState()
      Get the current BatchState (this is useful when performing row key join)

    • setBatchState

      void setBatchState(AbstractRecordBatch.BatchState newState)
      Set the BatchState (this is useful when performing row key join)
      Parameters:
      newState -

    • setRowKeyJoinState

      void setRowKeyJoinState(RowKeyJoin.RowKeyJoinState newState)
      Set the RowKeyJoinState (this is useful for maintaining state for row key join algorithm)
      Parameters:
      newState -

    • getRowKeyJoinState

      RowKeyJoin.RowKeyJoinState getRowKeyJoinState()
      Get the current RowKeyJoinState.