You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gluten.apache.org by ru...@apache.org on 2026/04/17 08:54:37 UTC
(gluten) branch main updated: [GLUTEN-9456][VL] Override clone in GlutenDirectBufferedInput (#11933)
This is an automated email from the ASF dual-hosted git repository.
rui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 139c332edc [GLUTEN-9456][VL] Override clone in GlutenDirectBufferedInput (#11933)
139c332edc is described below
commit 139c332edcef466e0270a1b922a400b3d237241d
Author: Rui Mo <ru...@apache.org>
AuthorDate: Fri Apr 17 09:54:30 2026 +0100
[GLUTEN-9456][VL] Override clone in GlutenDirectBufferedInput (#11933)
---
.github/workflows/velox_backend_x86.yml | 2 +-
cpp/velox/memory/GlutenDirectBufferedInput.h | 26 ++++++++++++++++++++++++++
2 files changed, 27 insertions(+), 1 deletion(-)
diff --git a/.github/workflows/velox_backend_x86.yml b/.github/workflows/velox_backend_x86.yml
index af17ac5ddb..a39fc65e87 100644
--- a/.github/workflows/velox_backend_x86.yml
+++ b/.github/workflows/velox_backend_x86.yml
@@ -156,7 +156,7 @@ jobs:
path: /root/.m2/repository/org/apache/arrow/
- name: Setup tzdata
run: |
- #sed -i 's|http://archive|http://us.archive|g' /etc/apt/sources.list
+ sed -i 's|http://archive|http://eu.archive|g' /etc/apt/sources.list
if [ "${{ matrix.os }}" = "ubuntu:22.04" ]; then
apt-get update
TZ="Etc/GMT" DEBIAN_FRONTEND=noninteractive apt-get install -y tzdata
diff --git a/cpp/velox/memory/GlutenDirectBufferedInput.h b/cpp/velox/memory/GlutenDirectBufferedInput.h
index 98b7fff9d9..d5b588770e 100644
--- a/cpp/velox/memory/GlutenDirectBufferedInput.h
+++ b/cpp/velox/memory/GlutenDirectBufferedInput.h
@@ -67,6 +67,32 @@ class GlutenDirectBufferedInput : public facebook::velox::dwio::common::DirectBu
}
coalescedLoads_.clear();
}
+
+ std::unique_ptr<facebook::velox::dwio::common::BufferedInput> clone() const override {
+ return std::unique_ptr<facebook::velox::dwio::common::BufferedInput>(new GlutenDirectBufferedInput(
+ input_, fileNum_, tracker_, groupId_, ioStatistics_, ioStats_, executor_, options_));
+ }
+
+ private:
+ // Constructor used by clone().
+ GlutenDirectBufferedInput(
+ std::shared_ptr<facebook::velox::dwio::common::ReadFileInputStream> input,
+ facebook::velox::StringIdLease fileNum,
+ std::shared_ptr<facebook::velox::cache::ScanTracker> tracker,
+ facebook::velox::StringIdLease groupId,
+ std::shared_ptr<facebook::velox::io::IoStatistics> ioStatistics,
+ std::shared_ptr<facebook::velox::IoStats> ioStats,
+ folly::Executor* executor,
+ const facebook::velox::io::ReaderOptions& readerOptions)
+ : DirectBufferedInput(
+ std::move(input),
+ std::move(fileNum),
+ std::move(tracker),
+ std::move(groupId),
+ std::move(ioStatistics),
+ std::move(ioStats),
+ executor,
+ readerOptions) {}
};
} // namespace gluten
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@gluten.apache.org
For additional commands, e-mail: commits-help@gluten.apache.org