Function garrow_execute_plan_build_node

c_glib/arrow-glib/compute.cpp:2266–2295

* garrow_execute_plan_build_node: * @plan: A #GArrowExecutePlan. * @factory_name: A factory name to build a #GArrowExecuteNode. * @inputs: (element-type GArrowExecuteNode): An inputs to execute new node. * @options: A #GArrowExecuteNodeOptions for new node. * @error: (nullable): Return location for a #GError or %NULL. * * Returns: (transfer full): A newly built and added #GArrowExecuteNode

 * Since: 6.0.0
 */
GArrowExecuteNode *
garrow_execute_plan_build_node(GArrowExecutePlan *plan,
                               const gchar *factory_name,
                               GList *inputs,
                               GArrowExecuteNodeOptions *options,
                               GError **error)
{
  auto arrow_plan = garrow_execute_plan_get_raw(plan);
  std::vector<arrow::acero::ExecNode *> arrow_inputs;
  for (auto node = inputs; node; node = node->next) {
    auto arrow_node = garrow_execute_node_get_raw(GARROW_EXECUTE_NODE(node->data));
    arrow_inputs.push_back(arrow_node);
  }
  auto arrow_options = garrow_execute_node_options_get_raw(options);
  auto arrow_node_result = arrow::acero::MakeExecNode(factory_name,
                                                      arrow_plan.get(),
                                                      arrow_inputs,
                                                      *arrow_options);
  if (garrow::check(error, arrow_node_result, "[execute-plan][build-node]")) {
    auto arrow_node = *arrow_node_result;
    arrow_node->SetLabel(factory_name);
    auto node = garrow_execute_node_new_raw(arrow_node, options);
    g_object_ref(node);
    auto priv = GARROW_EXECUTE_PLAN_GET_PRIVATE(plan);
    priv->nodes = g_list_prepend(priv->nodes, node);
    return node;
  } else {
    return NULL;
  }
}

/**
 * garrow_execute_plan_build_source_node: