quickstep-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zuyu <...@git.apache.org>
Subject [GitHub] incubator-quickstep pull request #45: QUICKSTEP-20: PhysicalGenerator suppor...
Date Tue, 28 Jun 2016 18:24:46 GMT
Github user zuyu commented on a diff in the pull request:

    https://github.com/apache/incubator-quickstep/pull/45#discussion_r68814000
  
    --- Diff: query_optimizer/physical/WindowAggregate.hpp ---
    @@ -0,0 +1,133 @@
    +/**
    + *   Copyright 2011-2015 Quickstep Technologies LLC.
    + *   Copyright 2015 Pivotal Software, Inc.
    + *   Copyright 2016, Quickstep Research Group, Computer Sciences Department,
    + *     University of Wisconsin—Madison.
    + *
    + *   Licensed under the Apache License, Version 2.0 (the "License");
    + *   you may not use this file except in compliance with the License.
    + *   You may obtain a copy of the License at
    + *
    + *       http://www.apache.org/licenses/LICENSE-2.0
    + *
    + *   Unless required by applicable law or agreed to in writing, software
    + *   distributed under the License is distributed on an "AS IS" BASIS,
    + *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    + *   See the License for the specific language governing permissions and
    + *   limitations under the License.
    + **/
    +
    +#ifndef QUICKSTEP_QUERY_OPTIMIZER_PHYSICAL_WINDOW_AGGREGATE_HPP_
    +#define QUICKSTEP_QUERY_OPTIMIZER_PHYSICAL_WINDOW_AGGREGATE_HPP_
    +
    +#include <memory>
    +#include <string>
    +#include <vector>
    +
    +#include "query_optimizer/OptimizerTree.hpp"
    +#include "query_optimizer/expressions/Alias.hpp"
    +#include "query_optimizer/expressions/AttributeReference.hpp"
    +#include "query_optimizer/expressions/ExpressionUtil.hpp"
    +#include "query_optimizer/expressions/NamedExpression.hpp"
    +#include "query_optimizer/physical/Physical.hpp"
    +#include "query_optimizer/physical/PhysicalType.hpp"
    +#include "utility/Macros.hpp"
    +
    +#include "glog/logging.h"
    +
    +namespace quickstep {
    +namespace optimizer {
    +namespace physical {
    +
    +/** \addtogroup OptimizerLogical
    + *  @{
    + */
    +
    +class WindowAggregate;
    +typedef std::shared_ptr<const WindowAggregate> WindowAggregatePtr;
    +
    +/**
    + * @brief Window Aggregate operator that computes window aggregate expressions.
    + */
    +class WindowAggregate : public Physical {
    + public:
    +  PhysicalType getPhysicalType() const override {
    +    return PhysicalType::kWindowAggregate;
    +  }
    +
    +  std::string getName() const override { return "WindowAggregate"; }
    +
    +  /**
    +   * @return The input physical node.
    +   */
    +  const PhysicalPtr input() const { return input_; }
    +
    +  /**
    +   * @return Window aggregate expression.
    +   */
    +  inline const expressions::AliasPtr window_aggregate_expression() const {
    +    return window_aggregate_expression_;
    +  }
    +
    +  PhysicalPtr copyWithNewChildren(
    +      const std::vector<PhysicalPtr> &new_children) const override {
    +    DCHECK_EQ(getNumChildren(), new_children.size());
    +    return Create(new_children[0], window_aggregate_expression_);
    +  }
    +
    +  std::vector<expressions::AttributeReferencePtr> getOutputAttributes() const override;
    +
    +  std::vector<expressions::AttributeReferencePtr> getReferencedAttributes() const
override;
    +
    +  bool maybeCopyWithPrunedExpressions(
    +      const expressions::UnorderedNamedExpressionSet &referenced_expressions,
    +      PhysicalPtr *output) const override {
    +    // The project expressions for an WindowAggregate cannot be changed.
    +    return false;
    +  }
    +
    +  /**
    +   * @brief Creates an WindowAggregate physical node.
    +   *
    +   * @param input The input node.
    +   * @param window_aggregate_expression The window aggregate expression.
    +   * @return An immutable WindowAggregate node.
    +   */
    +  static WindowAggregatePtr Create(
    +      PhysicalPtr input,
    +      const expressions::AliasPtr &window_aggregate_expression) {
    +    return WindowAggregatePtr(new WindowAggregate(input,
    +                                                  window_aggregate_expression));
    +  }
    +
    + protected:
    +  void getFieldStringItems(
    +      std::vector<std::string> *inline_field_names,
    +      std::vector<std::string> *inline_field_values,
    +      std::vector<std::string> *non_container_child_field_names,
    +      std::vector<OptimizerTreeBaseNodePtr> *non_container_child_fields,
    +      std::vector<std::string> *container_child_field_names,
    +      std::vector<std::vector<OptimizerTreeBaseNodePtr>> *container_child_fields)
const override;
    +
    + private:
    +  WindowAggregate(
    +      PhysicalPtr input,
    --- End diff --
    
    Ditto for the const reference to a `shared_ptr`.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message