This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 9d87bbfb745 [Chore] remove unused code (#38903)
9d87bbfb745 is described below
commit 9d87bbfb7451f9a278d2da1f5aa32cf9bdf14b5b
Author: Vallish Pai <[email protected]>
AuthorDate: Sat Aug 17 15:09:55 2024 +0530
[Chore] remove unused code (#38903)
## Proposed changes
Issue Number: close #xxx
remove unused class
---
be/src/pipeline/exec/exchange_sink_buffer.h | 13 -------------
1 file changed, 13 deletions(-)
diff --git a/be/src/pipeline/exec/exchange_sink_buffer.h
b/be/src/pipeline/exec/exchange_sink_buffer.h
index 2a0d75e42cb..2d30a492a0d 100644
--- a/be/src/pipeline/exec/exchange_sink_buffer.h
+++ b/be/src/pipeline/exec/exchange_sink_buffer.h
@@ -53,19 +53,6 @@ class ExchangeSinkLocalState;
namespace vectorized {
class PipChannel;
-template <typename T>
-struct AtomicWrapper {
- std::atomic<T> _value;
-
- AtomicWrapper() : _value() {}
-
- AtomicWrapper(const std::atomic<T>& a) : _value(a.load()) {}
-
- AtomicWrapper(const AtomicWrapper& other) : _value(other._value.load()) {}
-
- AtomicWrapper& operator=(const AtomicWrapper& other) {
_value.store(other._a.load()); }
-};
-
// We use BroadcastPBlockHolder to hold a broadcasted PBlock. For broadcast
shuffle, one PBlock
// will be shared between different channel, so we have to use a ref count to
mark if this
// PBlock is available for next serialization.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
