RelModify Class Reference

#include <RelAlgAbstractInterpreter.h>

Inheritance diagram for RelModify:

Collaboration diagram for RelModify:

Public Types
enum	ModifyOperation { ModifyOperation::Insert, ModifyOperation::Delete, ModifyOperation::Update }
using	RelAlgNodeInputPtr = std::shared_ptr< const RelAlgNode >
using	TargetColumnList = std::vector< std::string >

Public Member Functions
	RelModify (Catalog_Namespace::Catalog const &cat, TableDescriptor const *const td, bool flattened, std::string const &op_string, TargetColumnList const &target_column_list, RelAlgNodeInputPtr input)
	RelModify (Catalog_Namespace::Catalog const &cat, TableDescriptor const *const td, bool flattened, ModifyOperation op, TargetColumnList const &target_column_list, RelAlgNodeInputPtr input)
TableDescriptor const *const	getTableDescriptor () const
bool const	isFlattened () const
ModifyOperation	getOperation () const
TargetColumnList const &	getUpdateColumnNames ()
int	getUpdateColumnCount () const
size_t	size () const override
std::shared_ptr< RelAlgNode >	deepCopy () const override
std::string	toString () const override
void	applyUpdateModificationsToInputNode ()
void	applyDeleteModificationsToInputNode ()
Public Member Functions inherited from RelAlgNode
	RelAlgNode ()
virtual	~RelAlgNode ()
void	setContextData (const void *context_data) const
void	setOutputMetainfo (const std::vector< TargetMetaInfo > &targets_metainfo) const
const std::vector < TargetMetaInfo > &	getOutputMetainfo () const
unsigned	getId () const
bool	hasContextData () const
const void *	getContextData () const
const size_t	inputCount () const
const RelAlgNode *	getInput (const size_t idx) const
std::shared_ptr< const RelAlgNode >	getAndOwnInput (const size_t idx) const
void	addManagedInput (std::shared_ptr< const RelAlgNode > input)
bool	hasInput (const RelAlgNode *needle) const
virtual void	replaceInput (std::shared_ptr< const RelAlgNode > old_input, std::shared_ptr< const RelAlgNode > input)
bool	isNop () const
void	markAsNop ()

Static Public Member Functions
static std::string	yieldModifyOperationString (ModifyOperation const op)
static ModifyOperation	yieldModifyOperationEnum (std::string const &op_string)
Static Public Member Functions inherited from RelAlgNode
static void	resetRelAlgFirstId () noexcept

Private Attributes
Catalog_Namespace::Catalog const &	catalog_
const TableDescriptor *	table_descriptor_
bool	flattened_
ModifyOperation	operation_
TargetColumnList	target_column_list_

Additional Inherited Members
Protected Attributes inherited from RelAlgNode
std::vector< std::shared_ptr < const RelAlgNode > >	inputs_
const unsigned	id_

Detailed Description

Definition at line 1199 of file RelAlgAbstractInterpreter.h.

Member Typedef Documentation

using RelModify::RelAlgNodeInputPtr = std::shared_ptr<const RelAlgNode>

Definition at line 1202 of file RelAlgAbstractInterpreter.h.

using RelModify::TargetColumnList = std::vector<std::string>

Definition at line 1203 of file RelAlgAbstractInterpreter.h.

Member Enumeration Documentation

enum RelModify::ModifyOperation

strong

Enumerator
Insert
Delete
Update

Definition at line 1201 of file RelAlgAbstractInterpreter.h.

{ Insert, Delete, Update };

Constructor & Destructor Documentation

RelModify::RelModify ( Catalog_Namespace::Catalog const &  cat, TableDescriptor const *const  td, bool  flattened, std::string const &  op_string, TargetColumnList const &  target_column_list, RelAlgNodeInputPtr  input  )

inline

Definition at line 1232 of file RelAlgAbstractInterpreter.h.

References RelAlgNode::inputs_.

      : catalog_(cat)
      , table_descriptor_(td)
      , flattened_(flattened)
      , operation_(yieldModifyOperationEnum(op_string))
      , target_column_list_(target_column_list) {
    inputs_.push_back(input);
  }

RelModify::RelModify ( Catalog_Namespace::Catalog const &  cat, TableDescriptor const *const  td, bool  flattened, ModifyOperation  op, TargetColumnList const &  target_column_list, RelAlgNodeInputPtr  input  )

inline

Definition at line 1246 of file RelAlgAbstractInterpreter.h.

References RelAlgNode::inputs_.

      : catalog_(cat)
      , table_descriptor_(td)
      , flattened_(flattened)
      , operation_(op)
      , target_column_list_(target_column_list) {
    inputs_.push_back(input);
  }

Member Function Documentation

void RelModify::applyDeleteModificationsToInputNode ( )

inline

Definition at line 1349 of file RelAlgAbstractInterpreter.h.

References CHECK(), RelProject::injectOffsetInFragmentExpr(), RelAlgNode::inputs_, ModifyManipulationTarget::setDeleteViaSelectFlag(), and ModifyManipulationTarget::setModifiedTableDescriptor().

                                             {
    RelProject const* previous_project_node =
        dynamic_cast<RelProject const*>(inputs_[0].get());
    CHECK(previous_project_node != nullptr);
    previous_project_node->setDeleteViaSelectFlag();
    previous_project_node->injectOffsetInFragmentExpr();
    previous_project_node->setModifiedTableDescriptor(table_descriptor_);
  }

Here is the call graph for this function:

void RelModify::applyUpdateModificationsToInputNode ( )

inline

Definition at line 1287 of file RelAlgAbstractInterpreter.h.

References catalog_(), CHECK(), RelAlgNode::inputs_, ModifyManipulationTarget::setModifiedTableDescriptor(), ModifyManipulationTarget::setTargetColumns(), ModifyManipulationTarget::setUpdateViaSelectFlag(), ModifyManipulationTarget::setVarlenUpdateRequired(), and RelProject::visitScalarExprs().

                                             {
    RelProject const* previous_project_node =
        dynamic_cast<RelProject const*>(inputs_[0].get());
    CHECK(previous_project_node != nullptr);

    previous_project_node->setUpdateViaSelectFlag();
    // remove the offset column in the projection for update handling
    target_column_list_.pop_back();

    previous_project_node->setModifiedTableDescriptor(table_descriptor_);
    previous_project_node->setTargetColumns(target_column_list_);

    int target_update_column_expr_start = 0;
    int target_update_column_expr_end = (int)(target_column_list_.size() - 1);
    CHECK(target_update_column_expr_start >= 0);
    CHECK(target_update_column_expr_end >= 0);

    bool varlen_update_required = false;

    auto varlen_scan_visitor = [this,
                                &varlen_update_required,
                                target_update_column_expr_start,
                                target_update_column_expr_end](int index) {
      if (index >= target_update_column_expr_start &&
          index <= target_update_column_expr_end) {
        auto target_index = index - target_update_column_expr_start;

        auto* column_desc = catalog_.getMetadataForColumn(
            table_descriptor_->tableId, target_column_list_[target_index]);
        CHECK(column_desc);

        if (table_descriptor_->nShards) {
          const auto shard_cd =
              catalog_.getShardColumnMetadataForTable(table_descriptor_);
          CHECK(shard_cd);
          if ((column_desc->columnName == shard_cd->columnName)) {
            throw std::runtime_error("UPDATE of a shard key is currently unsupported.");
          }
        }

        // Check for valid types
        if (is_feature_enabled<VarlenUpdates>()) {
          if (column_desc->columnType.is_varlen()) {
            varlen_update_required = true;
          }

          if (column_desc->columnType.is_geometry()) {
            throw std::runtime_error("UPDATE of a geo column is unsupported.");
          }
        } else {
          if (column_desc->columnType.is_varlen()) {
            throw std::runtime_error(
                "UPDATE of a none-encoded string, geo, or array column is unsupported.");
          }
        }
      }
    };

    previous_project_node->visitScalarExprs(varlen_scan_visitor);
    previous_project_node->setVarlenUpdateRequired(varlen_update_required);
  }

Here is the call graph for this function:

std::shared_ptr<RelAlgNode> RelModify::deepCopy ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1267 of file RelAlgAbstractInterpreter.h.

References catalog_(), and RelAlgNode::inputs_.

                                                      {
    return std::make_shared<RelModify>(catalog_,
                                       table_descriptor_,
                                       flattened_,
                                       operation_,
                                       target_column_list_,
                                       inputs_[0]);
  }

Here is the call graph for this function:

ModifyOperation RelModify::getOperation ( ) const

inline

Definition at line 1262 of file RelAlgAbstractInterpreter.h.

{ return operation_; }

TableDescriptor const* const RelModify::getTableDescriptor ( ) const

inline

Definition at line 1260 of file RelAlgAbstractInterpreter.h.

{ return table_descriptor_; }

int RelModify::getUpdateColumnCount ( ) const

inline

Definition at line 1264 of file RelAlgAbstractInterpreter.h.

{ return target_column_list_.size(); }

TargetColumnList const& RelModify::getUpdateColumnNames ( )

inline

Definition at line 1263 of file RelAlgAbstractInterpreter.h.

{ return target_column_list_; }

bool const RelModify::isFlattened ( ) const

inline

Definition at line 1261 of file RelAlgAbstractInterpreter.h.

{ return flattened_; }

size_t RelModify::size ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1266 of file RelAlgAbstractInterpreter.h.

{ return 0; }

std::string RelModify::toString ( ) const

inlineoverridevirtual

Implements RelAlgNode.

Definition at line 1276 of file RelAlgAbstractInterpreter.h.

References to_string().

                                      {
    std::ostringstream result_stream;
    result_stream << std::boolalpha
                  << "(RelModify<" + std::to_string(reinterpret_cast<uint64_t>(this)) +
                         "> "
                  << table_descriptor_->tableName << " flattened= " << flattened_
                  << " operation= " << yieldModifyOperationString(operation_) << ")";

    return result_stream.str();
  }

Here is the call graph for this function:

static ModifyOperation RelModify::yieldModifyOperationEnum ( std::string const &  op_string )

inlinestatic

Definition at line 1219 of file RelAlgAbstractInterpreter.h.

                                                                              {
    if (op_string == "INSERT") {
      return ModifyOperation::Insert;
    } else if (op_string == "DELETE") {
      return ModifyOperation::Delete;
    } else if (op_string == "UPDATE") {
      return ModifyOperation::Update;
    }

    throw std::runtime_error(
        std::string("Unsupported logical modify operation encountered " + op_string));
  }

static std::string RelModify::yieldModifyOperationString ( ModifyOperation const  op )

inlinestatic

Definition at line 1205 of file RelAlgAbstractInterpreter.h.

                                                                        {
    switch (op) {
      case ModifyOperation::Delete:
        return "DELETE";
      case ModifyOperation::Insert:
        return "INSERT";
      case ModifyOperation::Update:
        return "UPDATE";
      default:
        break;
    }
    throw std::runtime_error("Unexpected ModifyOperation enum encountered.");
  }

Member Data Documentation

Catalog_Namespace::Catalog const& RelModify::catalog_

private

Definition at line 1359 of file RelAlgAbstractInterpreter.h.

bool RelModify::flattened_

private

Definition at line 1361 of file RelAlgAbstractInterpreter.h.

ModifyOperation RelModify::operation_

private

Definition at line 1362 of file RelAlgAbstractInterpreter.h.

const TableDescriptor* RelModify::table_descriptor_

private

Definition at line 1360 of file RelAlgAbstractInterpreter.h.

TargetColumnList RelModify::target_column_list_

private

Definition at line 1363 of file RelAlgAbstractInterpreter.h.

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/RelAlgAbstractInterpreter.h