This is an automated email from the ASF dual-hosted git repository.
westonpace pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git.
from 3cacc85 ARROW-14247: [C++] Fix Valgrind errors in parquet-arrow-test
add 4b8ffe4 ARROW-13542: [C++][Compute][Dataset] Add dataset::WriteNode
for writing rows from an ExecPlan to disk
No new revisions were added by this update.
Summary of changes:
cpp/src/arrow/compute/exec/exec_plan.cc | 2 +-
cpp/src/arrow/compute/exec/options.h | 20 ++++
cpp/src/arrow/compute/exec/plan_test.cc | 102 +++++++++++++++++
cpp/src/arrow/compute/exec/sink_node.cc | 100 +++++++++++++++++
cpp/src/arrow/compute/exec/source_node.cc | 105 +++++++++---------
cpp/src/arrow/compute/exec/util.h | 3 +
cpp/src/arrow/dataset/CMakeLists.txt | 1 +
cpp/src/arrow/dataset/dataset_writer.cc | 4 +-
cpp/src/arrow/dataset/file_base.cc | 154 +++++++++++++++++---------
cpp/src/arrow/dataset/file_base.h | 16 +++
cpp/src/arrow/{result.cc => dataset/plan.cc} | 23 ++--
cpp/src/arrow/dataset/{projector.h => plan.h} | 11 +-
cpp/src/arrow/dataset/scanner.cc | 22 ++--
cpp/src/arrow/dataset/scanner.h | 13 +--
cpp/src/arrow/dataset/scanner_test.cc | 1 +
cpp/src/arrow/dataset/test_util.h | 109 +++++++++---------
cpp/src/arrow/util/async_util.cc | 96 +++++++++++++++-
cpp/src/arrow/util/async_util.h | 67 ++++++++++-
cpp/src/arrow/util/async_util_test.cc | 132 +++++++++++++++-------
cpp/src/arrow/util/future.cc | 11 ++
cpp/src/arrow/util/future.h | 11 ++
python/pyarrow/tests/test_dataset.py | 25 +++--
r/src/compute-exec.cpp | 1 +
23 files changed, 786 insertions(+), 243 deletions(-)
copy cpp/src/arrow/{result.cc => dataset/plan.cc} (69%)
copy cpp/src/arrow/dataset/{projector.h => plan.h} (81%)
