plannerInt.h 1.8 KB
Newer Older
H
Hongze Cheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef _TD_PLANNER_INT_H_
#define _TD_PLANNER_INT_H_

#ifdef __cplusplus
extern "C" {
#endif

23 24 25
#include "common.h"
#include "tarray.h"
#include "planner.h"
H
Haojun Liao 已提交
26
#include "taosmsg.h"
27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56

typedef struct SQueryNodeBasicInfo {
  int32_t   type;
  char     *name;
} SQueryNodeBasicInfo;

typedef struct SQueryTableInfo {
  char     *tableName;
  uint64_t  uid;
  int32_t   tid;
} SQueryTableInfo;

typedef struct SQueryNode {
  SQueryNodeBasicInfo info;
  SQueryTableInfo     tableInfo;
  SSchema            *pSchema;      // the schema of the input SSDatablock
  int32_t             numOfCols;    // number of input columns
  struct SExprInfo   *pExpr;        // the query functions or sql aggregations
  int32_t             numOfOutput;  // number of result columns, which is also the number of pExprs
  void               *pExtInfo;     // additional information
  // previous operator to generated result for current node to process
  // in case of join, multiple prev nodes exist.
  SArray             *pPrevNodes;   // upstream nodes
  struct SQueryNode  *nextNode;
} SQueryNode;

typedef struct SQueryPhyNode {

} SQueryPhyNode;

H
Hongze Cheng 已提交
57 58 59 60 61
#ifdef __cplusplus
}
#endif

#endif /*_TD_PLANNER_INT_H_*/