PG/GP limit...offset...实现机制

typedef enum
{
  LIMIT_INITIAL,        /*LIMIT node初始状态 */
  LIMIT_RESCAN,      /* rescan after recomputing parameters */
  LIMIT_EMPTY,        /* 没有要返回的行了*/
  LIMIT_INWINDOW,      /* have returned a row in the window */
  LIMIT_SUBPLANEOF,    /* at EOF of subplan (within window) */
  LIMIT_WINDOWEND,    /* stepped off end of window */
  LIMIT_WINDOWSTART    /* stepped off beginning of window */
} LimitStateCond;

tatic TupleTableSlot *  ExecLimit_guts(PlanState *pstate)
{
  switch (node->lstate){
    case LIMIT_INITIAL:
      //计算limit及offset
      recompute_limits(node);
      //计算完立即进入LIMIT_RESCAN
    case LIMIT_RESCAN://fetch tuple知道到达offset处
      if (!ScanDirectionIsForward(direction))
        return NULL;
      //limit窗口为0，返回null
      if (node->count <= 0 && !node->noCount){
        node->lstate = LIMIT_EMPTY;
        return NULL;
      }
      for (;;){
        slot = ExecProcNode(outerPlan);
        if (TupIsNull(slot)){
          //子节点没有slot了
          node->lstate = LIMIT_EMPTY;
          return NULL;
        }
        node->subSlot = slot;//下层节点获取后存入这里
        if (++node->position > node->offset)
          break;//满足offset窗口
      }
      //获取了满足窗口的第一个tuple
      node->lstate = LIMIT_INWINDOW;
      break;
    case LIMIT_EMPTY:
      return NULL;
    case LIMIT_INWINDOW:
      if (ScanDirectionIsForward(direction)){
        if (!node->noCount && node->position - node->offset >= node->count){
          node->lstate = LIMIT_WINDOWEND;//达到了limit个数
          if (!(node->ps.state->es_top_eflags & EXEC_FLAG_BACKWARD))
            (void) ExecShutdownNode(outerPlan);
          return NULL;
        }//fetch一个tuple
        slot = ExecProcNode(outerPlan);
        if (TupIsNull(slot)){
          node->lstate = LIMIT_SUBPLANEOF;
          return NULL;
        }
        node->subSlot = slot;
        node->position++;
      }else{
        if (node->position <= node->offset + 1){
          node->lstate = LIMIT_WINDOWSTART;
          return NULL;
        }
        slot = ExecProcNode(outerPlan);
        if (TupIsNull(slot))
          elog(ERROR, "LIMIT subplan failed to run backwards");
        node->subSlot = slot;
        node->position--;
      }
      break;
    case LIMIT_SUBPLANEOF:
      if (ScanDirectionIsForward(direction))
        return NULL;
      slot = ExecProcNode(outerPlan);
      if (TupIsNull(slot))
        elog(ERROR, "LIMIT subplan failed to run backwards");
      node->subSlot = slot;
      node->lstate = LIMIT_INWINDOW;
      /* position does not change 'cause we didn't advance it before */
      break;

    case LIMIT_WINDOWEND:
      if (ScanDirectionIsForward(direction))
        return NULL;

      slot = node->subSlot;
      node->lstate = LIMIT_INWINDOW;
      /* position does not change 'cause we didn't advance it before */
      break;

    case LIMIT_WINDOWSTART:
      if (!ScanDirectionIsForward(direction))
        return NULL;
      slot = node->subSlot;
      node->lstate = LIMIT_INWINDOW;
      break;
    default:
      elog(ERROR, "impossible LIMIT state: %d",
         (int) node->lstate);
      slot = NULL;    /* keep compiler quiet */
      break;
  }
  return slot;
}