chore(substrait): bump to v0.42.1 (#95)

src/substrait/textplan/converter/BasePlanProtoVisitor.cpp

@@ -973,6 +973,44 @@ std::any BasePlanProtoVisitor::visitCrossRelation(
  return std::nullopt;
 }
 
+std::any BasePlanProtoVisitor::visitReferenceRelation(
+ const ::substrait::proto::ReferenceRel& relation) {
+ return std::nullopt;
+}
+
+std::any BasePlanProtoVisitor::visitWriteRelation(
+ const ::substrait::proto::WriteRel& relation) {
+ // TODO -- Add support for write_type.
+ if (relation.has_table_schema()) {
+ visitNamedStruct(relation.table_schema());
+ }
+ if (relation.has_input()) {
+ visitRelation(relation.input());
+ }
+ if (relation.has_common()) {
+ visitRelationCommon(relation.common());
+ }
+ return std::nullopt;
+}
+
+std::any BasePlanProtoVisitor::visitDdlRelation(
+ const ::substrait::proto::DdlRel& relation) {
+ // TODO -- Add support for write_type.
+ if (relation.has_table_schema()) {
+ visitNamedStruct(relation.table_schema());
+ }
+ if (relation.has_table_defaults()) {
+ visitExpressionLiteralStruct(relation.table_defaults());
+ }
+ if (relation.has_view_definition()) {
+ visitRelation(relation.view_definition());
+ }
+ if (relation.has_common()) {
+ visitRelationCommon(relation.common());
+ }
+ return std::nullopt;
+}
+
 std::any BasePlanProtoVisitor::visitHashJoinRelation(
  const ::substrait::proto::HashJoinRel& relation) {
  if (relation.has_common()) {
@@ -1025,6 +1063,26 @@ std::any BasePlanProtoVisitor::visitMergeJoinRelation(
  return std::nullopt;
 }
 
+std::any BasePlanProtoVisitor::visitNestedLoopJoinRelation(
+ const ::substrait::proto::NestedLoopJoinRel& relation) {
+ if (relation.has_common()) {
+ visitRelationCommon(relation.common());
+ }
+ if (relation.has_left()) {
+ visitRelation(relation.left());
+ }
+ if (relation.has_right()) {
+ visitRelation(relation.right());
+ }
+ if (relation.has_expression()) {
+ visitExpression(relation.expression());
+ }
+ if (relation.has_advanced_extension()) {
+ visitAdvancedExtension(relation.advanced_extension());
+ };
+ return std::nullopt;
+}
+
 std::any BasePlanProtoVisitor::visitWindowRelation(
  const ::substrait::proto::ConsistentPartitionWindowRel& relation) {
  if (relation.has_common()) {
@@ -1103,10 +1161,18 @@ std::any BasePlanProtoVisitor::visitRelation(
  return visitExtensionLeafRelation(relation.extension_leaf());
  case ::substrait::proto::Rel::RelTypeCase::kCross:
  return visitCrossRelation(relation.cross());
+ case ::substrait::proto::Rel::RelTypeCase::kReference:
+ return visitReferenceRelation(relation.reference());
+ case ::substrait::proto::Rel::RelTypeCase::kWrite:
+ return visitWriteRelation(relation.write());
+ case ::substrait::proto::Rel::RelTypeCase::kDdl:
+ return visitDdlRelation(relation.ddl());
  case ::substrait::proto::Rel::RelTypeCase::kHashJoin:
  return visitHashJoinRelation(relation.hash_join());
  case ::substrait::proto::Rel::RelTypeCase::kMergeJoin:
  return visitMergeJoinRelation(relation.merge_join());
+ case ::substrait::proto::Rel::RelTypeCase::kNestedLoopJoin:
+ return visitNestedLoopJoinRelation(relation.nested_loop_join());
  case ::substrait::proto::Rel::kWindow:
  return visitWindowRelation(relation.window());
  case ::substrait::proto::Rel::kExchange:

src/substrait/textplan/converter/BasePlanProtoVisitor.h

@@ -170,10 +170,19 @@ class BasePlanProtoVisitor {
  const ::substrait::proto::ExtensionLeafRel& relation);
  virtual std::any visitCrossRelation(
  const ::substrait::proto::CrossRel& relation);
+
+ virtual std::any visitReferenceRelation(
+ const ::substrait::proto::ReferenceRel& relation);
+ virtual std::any visitWriteRelation(
+ const ::substrait::proto::WriteRel& relation);
+ virtual std::any visitDdlRelation(const ::substrait::proto::DdlRel& relation);
+
  virtual std::any visitHashJoinRelation(
  const ::substrait::proto::HashJoinRel& relation);
  virtual std::any visitMergeJoinRelation(
  const ::substrait::proto::MergeJoinRel& relation);
+ virtual std::any visitNestedLoopJoinRelation(
+ const ::substrait::proto::NestedLoopJoinRel& relation);
  virtual std::any visitWindowRelation(
  const ::substrait::proto::ConsistentPartitionWindowRel& relation);
  virtual std::any visitExchangeRelation(

src/substrait/textplan/converter/InitialPlanProtoVisitor.cpp

@@ -68,6 +68,14 @@ void eraseInputs(::substrait::proto::Rel* relation) {
  relation->mutable_cross()->clear_left();
  relation->mutable_cross()->clear_right();
  break;
+ case ::substrait::proto::Rel::kReference:
+ break;
+ case ::substrait::proto::Rel::kWrite:
+ relation->mutable_write()->clear_input();
+ break;
+ case ::substrait::proto::Rel::kDdl:
+ relation->mutable_ddl()->clear_view_definition();
+ break;
  case ::substrait::proto::Rel::kHashJoin:
  relation->mutable_hash_join()->clear_left();
  relation->mutable_hash_join()->clear_right();
@@ -76,6 +84,10 @@ void eraseInputs(::substrait::proto::Rel* relation) {
  relation->mutable_merge_join()->clear_left();
  relation->mutable_merge_join()->clear_right();
  break;
+ case ::substrait::proto::Rel::kNestedLoopJoin:
+ relation->mutable_nested_loop_join()->clear_left();
+ relation->mutable_nested_loop_join()->clear_right();
+ break;
  case ::substrait::proto::Rel::kWindow:
  relation->mutable_window()->clear_input();
  break;
@@ -117,10 +129,19 @@ ::google::protobuf::RepeatedField<int32_t> getOutputMapping(
  return relation.extension_leaf().common().emit().output_mapping();
  case ::substrait::proto::Rel::kCross:
  return relation.cross().common().emit().output_mapping();
+ case ::substrait::proto::Rel::kReference:
+ // There is no common message in a ReferenceRel.
+ break;
+ case ::substrait::proto::Rel::kWrite:
+ return relation.write().common().emit().output_mapping();
+ case ::substrait::proto::Rel::kDdl:
+ return relation.ddl().common().emit().output_mapping();
  case ::substrait::proto::Rel::kHashJoin:
  return relation.hash_join().common().emit().output_mapping();
  case ::substrait::proto::Rel::kMergeJoin:
  return relation.merge_join().common().emit().output_mapping();
+ case ::substrait::proto::Rel::kNestedLoopJoin:
+ return relation.nested_loop_join().common().emit().output_mapping();
  case ::substrait::proto::Rel::kWindow:
  return relation.window().common().emit().output_mapping();
  case ::substrait::proto::Rel::kExchange:
@@ -566,6 +587,14 @@ void InitialPlanProtoVisitor::updateLocalSchema(
  addFieldsToRelation(
  relationData, relation.cross().left(), relation.cross().right());
  break;
+ case ::substrait::proto::Rel::kReference:
+ break;
+ case ::substrait::proto::Rel::kWrite:
+ addFieldsToRelation(relationData, relation.write().input());
+ break;
+ case ::substrait::proto::Rel::kDdl:
+ addFieldsToRelation(relationData, relation.ddl().view_definition());
+ break;
  case ::substrait::proto::Rel::RelTypeCase::kHashJoin:
  addFieldsToRelation(
  relationData,
@@ -578,6 +607,12 @@ void InitialPlanProtoVisitor::updateLocalSchema(
  relation.merge_join().left(),
  relation.merge_join().right());
  break;
+ case ::substrait::proto::Rel::kNestedLoopJoin:
+ addFieldsToRelation(
+ relationData,
+ relation.nested_loop_join().left(),
+ relation.nested_loop_join().right());
+ break;
  case ::substrait::proto::Rel::kWindow:
  addFieldsToRelation(relationData, relation.window().input());
  break;

src/substrait/textplan/converter/PipelineVisitor.cpp

@@ -165,6 +165,17 @@ std::any PipelineVisitor::visitRelation(
  relationData->newPipelines.push_back(rightSymbol);
  break;
  }
+ case ::substrait::proto::Rel::kNestedLoopJoin: {
+ const auto* leftSymbol = symbolTable_->lookupSymbolByLocationAndType(
+ PROTO_LOCATION(relation.nested_loop_join().left()),
+ SymbolType::kRelation);
+ const auto* rightSymbol = symbolTable_->lookupSymbolByLocationAndType(
+ PROTO_LOCATION(relation.nested_loop_join().right()),
+ SymbolType::kRelation);
+ relationData->newPipelines.push_back(leftSymbol);
+ relationData->newPipelines.push_back(rightSymbol);
+ break;
+ }
  case ::substrait::proto::Rel::kWindow: {
  const auto* inputSymbol = symbolTable_->lookupSymbolByLocationAndType(
  PROTO_LOCATION(relation.window().input()), SymbolType::kRelation);
@@ -183,6 +194,16 @@ std::any PipelineVisitor::visitRelation(
  relationData->continuingPipeline = inputSymbol;
  break;
  }
+ case ::substrait::proto::Rel::kReference:
+ // TODO -- Add support for references in text plans.
+ break;
+ case ::substrait::proto::Rel::kWrite: {
+ const auto* inputSymbol = symbolTable_->lookupSymbolByLocationAndType(
+ PROTO_LOCATION(relation.write().input()), SymbolType::kRelation);
+ relationData->continuingPipeline = inputSymbol;
+ break;
+ }
+ case ::substrait::proto::Rel::kDdl:
  case ::substrait::proto::Rel::REL_TYPE_NOT_SET:
  break;
  }