project_physical_operator.h 1.2 KB
Newer Older
羽飞's avatar
羽飞 已提交
1
/* Copyright (c) 2021 OceanBase and/or its affiliates. All rights reserved.
羽飞's avatar
羽飞 已提交
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
miniob is licensed under Mulan PSL v2.
You can use this software according to the terms and conditions of the Mulan PSL v2.
You may obtain a copy of Mulan PSL v2 at:
         http://license.coscl.org.cn/MulanPSL2
THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
See the Mulan PSL v2 for more details. */

//
// Created by WangYunlai on 2022/07/01.
//

#pragma once

羽飞's avatar
羽飞 已提交
17
#include "sql/operator/physical_operator.h"
羽飞's avatar
羽飞 已提交
18

19 20 21 22
/**
 * @brief 选择/投影物理算子
 * @ingroup PhysicalOperator
 */
羽飞's avatar
羽飞 已提交
23 24
class ProjectPhysicalOperator : public PhysicalOperator
{
羽飞's avatar
羽飞 已提交
25
public:
羽飞's avatar
羽飞 已提交
26
  ProjectPhysicalOperator()
羽飞's avatar
羽飞 已提交
27 28
  {}

羽飞's avatar
羽飞 已提交
29
  virtual ~ProjectPhysicalOperator() = default;
羽飞's avatar
羽飞 已提交
30

31
  void add_projection(const Table *table, const FieldMeta *field);
羽飞's avatar
羽飞 已提交
32

L
Longda Feng 已提交
33 34 35 36 37
  PhysicalOperatorType type() const override
  {
    return PhysicalOperatorType::PROJECT;
  }

羽飞's avatar
羽飞 已提交
38
  RC open(Trx *trx) override;
羽飞's avatar
羽飞 已提交
39 40 41
  RC next() override;
  RC close() override;

羽飞's avatar
羽飞 已提交
42
  int tuple_cell_num() const
羽飞's avatar
羽飞 已提交
43 44 45 46
  {
    return tuple_.cell_num();
  }

L
Longda Feng 已提交
47 48
  Tuple *current_tuple() override;

羽飞's avatar
羽飞 已提交
49 50 51
private:
  ProjectTuple tuple_;
};