This is an automated email from the ASF dual-hosted git repository.
kou pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow.git
The following commit(s) were added to refs/heads/main by this push:
new dc09722284 GH-46153: [C++] Implement acero directory in Meson (#46154)
dc09722284 is described below
commit dc0972228448c8187629f03af1ff1c1d01b98ca3
Author: William Ayd <[email protected]>
AuthorDate: Tue May 6 20:05:35 2025 -0400
GH-46153: [C++] Implement acero directory in Meson (#46154)
### Rationale for this change
Improves coverage of the Meson build system configuration
### What changes are included in this PR?
This adds the Acero directory to Meson
### Are these changes tested?
Yes
### Are there any user-facing changes?
No
* GitHub Issue: #46153
Authored-by: Will Ayd <[email protected]>
Signed-off-by: Sutou Kouhei <[email protected]>
---
cpp/meson.build | 3 +-
cpp/meson.options | 1 +
cpp/src/arrow/acero/meson.build | 139 ++++++++++++++++++++++++++++++++++++++++
cpp/src/arrow/meson.build | 4 ++
4 files changed, 146 insertions(+), 1 deletion(-)
diff --git a/cpp/meson.build b/cpp/meson.build
index 66a216e3c4..0362f2afd0 100644
--- a/cpp/meson.build
+++ b/cpp/meson.build
@@ -66,7 +66,8 @@ needs_s3 = get_option('s3').enabled()
needs_filesystem = get_option('filesystem').enabled() or needs_azure or
needs_gcs or needs_hdfs or needs_s3
needs_integration = get_option('integration').enabled()
needs_tests = get_option('tests').enabled()
-needs_ipc = get_option('ipc').enabled() or needs_tests or needs_benchmarks
+needs_acero = get_option('acero').enabled()
+needs_ipc = get_option('ipc').enabled() or needs_tests or needs_acero or
needs_benchmarks
needs_testing = get_option('testing').enabled() or needs_tests or
needs_benchmarks or needs_integration
needs_json = get_option('json').enabled() or needs_testing
diff --git a/cpp/meson.options b/cpp/meson.options
index 33d66beefa..7b7008bd35 100644
--- a/cpp/meson.options
+++ b/cpp/meson.options
@@ -15,6 +15,7 @@
# specific language governing permissions and limitations
# under the License.
+option('acero', type: 'feature', description: 'Build the Arrow Acero Engine
Module')
option(
'azure',
type: 'feature',
diff --git a/cpp/src/arrow/acero/meson.build b/cpp/src/arrow/acero/meson.build
new file mode 100644
index 0000000000..6029610eb3
--- /dev/null
+++ b/cpp/src/arrow/acero/meson.build
@@ -0,0 +1,139 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you 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.
+
+install_headers(
+ [
+ 'accumulation_queue.h',
+ 'aggregate_node.h',
+ 'api.h',
+ 'asof_join_node.h',
+ 'backpressure_handler.h',
+ 'benchmark_util.h',
+ 'bloom_filter.h',
+ 'exec_plan.h',
+ 'hash_join_dict.h',
+ 'hash_join.h',
+ 'hash_join_node.h',
+ 'map_node.h',
+ 'options.h',
+ 'order_by_impl.h',
+ 'partition_util.h',
+ 'query_context.h',
+ 'schema_util.h',
+ 'task_util.h',
+ 'test_nodes.h',
+ 'time_series_util.h',
+ 'tpch_node.h',
+ 'type_fwd.h',
+ 'util.h',
+ 'visibility.h',
+ ],
+ subdir: 'arrow/acero',
+)
+
+arrow_acero_srcs = [
+ 'accumulation_queue.cc',
+ 'scalar_aggregate_node.cc',
+ 'groupby_aggregate_node.cc',
+ 'aggregate_internal.cc',
+ 'asof_join_node.cc',
+ 'bloom_filter.cc',
+ 'exec_plan.cc',
+ 'fetch_node.cc',
+ 'filter_node.cc',
+ 'hash_join.cc',
+ 'hash_join_dict.cc',
+ 'hash_join_node.cc',
+ 'map_node.cc',
+ 'options.cc',
+ 'order_by_node.cc',
+ 'order_by_impl.cc',
+ 'partition_util.cc',
+ 'pivot_longer_node.cc',
+ 'project_node.cc',
+ 'query_context.cc',
+ 'sink_node.cc',
+ 'sorted_merge_node.cc',
+ 'source_node.cc',
+ 'swiss_join.cc',
+ 'task_util.cc',
+ 'time_series_util.cc',
+ 'tpch_node.cc',
+ 'union_node.cc',
+ 'util.cc',
+]
+
+arrow_acero_lib = library(
+ 'arrow-acero',
+ sources: arrow_acero_srcs,
+ dependencies: [arrow_dep],
+)
+
+arrow_acero_dep = declare_dependency(link_with: [arrow_acero_lib])
+
+arrow_acero_testing_sources = ['test_nodes.cc', 'test_util_internal.cc'] +
arrow_compute_testing_srcs
+
+arrow_acero_tests = {
+ 'plan-test': {'sources': ['plan_test.cc', 'test_nodes_test.cc']},
+ 'source-node-test': {'sources': ['source_node_test.cc']},
+ 'fetch-node-test': {'sources': ['fetch_node_test.cc']},
+ 'order-by-node-test': {'sources': ['order_by_node_test.cc']},
+ 'hash-join-node-test': {
+ 'sources': ['hash_join_node_test.cc', 'bloom_filter_test.cc'],
+ },
+ 'pivot-longer-node-test': {'sources': ['pivot_longer_node_test.cc']},
+ 'asof-join-node-test': {'sources': ['asof_join_node_test.cc']},
+ 'sorted-merge-node-test': {'sources': ['sorted_merge_node_test.cc']},
+ 'tpch-node-test': {'sources': ['tpch_node_test.cc']},
+ 'union-node-test': {'sources': ['union_node_test.cc']},
+ 'aggregate-node-test': {'sources': ['aggregate_node_test.cc']},
+ 'util-test': {'sources': ['util_test.cc', 'task_util_test.cc']},
+ 'hash-aggregate-test': {'sources': ['hash_aggregate_test.cc']},
+ 'test-util-internal-test': {'sources': ['test_util_internal_test.cc']},
+}
+
+foreach key, val : arrow_acero_tests
+ exc = executable(
+ 'arrow-acero-@0@'.format(key),
+ sources: val['sources'] + arrow_acero_testing_sources,
+ dependencies: [arrow_acero_dep, arrow_test_dep],
+ )
+ test(key, exc)
+endforeach
+
+arrow_acero_benchmarks = {
+ 'expression-benchmark': {'sources': ['expression_benchmark.cc']},
+ 'filter-benchmark': {
+ 'sources': ['benchmark_util.cc', 'filter_benchmark.cc'],
+ },
+ 'project-benchmark': {
+ 'sources': ['benchmark_util.cc', 'project_benchmark.cc'],
+ },
+ 'asof-join-benchmark': {'sources': ['asof_join_benchmark.cc']},
+ 'tpch-benchmark': {'sources': ['tpch_benchmark.cc']},
+ 'aggregate-benchmark': {'sources': ['aggregate_benchmark.cc']},
+ 'hash-join-benchmark': {'sources': ['hash_join_benchmark.cc']},
+}
+
+foreach key, val : arrow_acero_benchmarks
+ exc = executable(
+ key,
+ sources: val['sources'] + arrow_acero_testing_sources,
+ dependencies: [arrow_acero_dep, arrow_benchmark_dep, gmock_dep],
+ )
+ benchmark(key, exc)
+endforeach
diff --git a/cpp/src/arrow/meson.build b/cpp/src/arrow/meson.build
index a7584b7a61..5f5052162d 100644
--- a/cpp/src/arrow/meson.build
+++ b/cpp/src/arrow/meson.build
@@ -674,6 +674,10 @@ if needs_csv
subdir('csv')
endif
+if needs_acero
+ subdir('acero')
+endif
+
if needs_filesystem
subdir('filesystem')
endif
