Function garrow_aggregate_node_options_new

c_glib/arrow-glib/compute.cpp:1740–1784

* garrow_aggregate_node_options_new: * @aggregations: (element-type GArrowAggregation): A list of #GArrowAggregation. * @keys: (nullable) (array length=n_keys): Group keys. * @n_keys: The number of @keys. * @error: (nullable): Return location for a #GError or %NULL. * * Returns: (nullable): A newly created #GArrowAggregateNodeOptions on success, * %NULL otherwise. * * Since: 6.0.0 */

 * Since: 6.0.0
 */
GArrowAggregateNodeOptions *
garrow_aggregate_node_options_new(GList *aggregations,
                                  const gchar **keys,
                                  gsize n_keys,
                                  GError **error)
{
  std::vector<arrow::compute::Aggregate> arrow_aggregates;
  std::vector<arrow::FieldRef> arrow_keys;
  for (auto node = aggregations; node; node = node->next) {
    auto aggregation_priv = GARROW_AGGREGATION_GET_PRIVATE(node->data);
    arrow::compute::FunctionOptions *function_options = nullptr;
    if (aggregation_priv->options) {
      function_options = garrow_function_options_get_raw(aggregation_priv->options);
    };
    std::vector<arrow::FieldRef> arrow_targets;
    if (!garrow_field_refs_add(arrow_targets,
                               aggregation_priv->input,
                               error,
                               "[aggregate-node-options][new][input]")) {
      return NULL;
    }
    arrow_aggregates.push_back({
      aggregation_priv->function,
      function_options ? function_options->Copy() : nullptr,
      arrow_targets[0],
      aggregation_priv->output,
    });
  }
  for (gsize i = 0; i < n_keys; ++i) {
    if (!garrow_field_refs_add(arrow_keys,
                               keys[i],
                               error,
                               "[aggregate-node-options][new][key]")) {
      return NULL;
    }
  }
  auto arrow_options = new arrow::acero::AggregateNodeOptions(std::move(arrow_aggregates),
                                                              std::move(arrow_keys));
  auto options =
    g_object_new(GARROW_TYPE_AGGREGATE_NODE_OPTIONS, "options", arrow_options, nullptr);
  auto priv = GARROW_AGGREGATE_NODE_OPTIONS_GET_PRIVATE(options);
  priv->aggregations =
    g_list_copy_deep(aggregations, reinterpret_cast<GCopyFunc>(g_object_ref), nullptr);
  return GARROW_AGGREGATE_NODE_OPTIONS(options);
}

/**
 * garrow_aggregate_node_options_get_aggregations: