Skip to content

Commit

Permalink
misc: Remove compatibility methods in ExchangeQueue (facebookincubato…
Browse files Browse the repository at this point in the history
…r#12196)

Summary: Pull Request resolved: facebookincubator#12196

Reviewed By: xiaoxmeng

Differential Revision: D68784003

fbshipit-source-id: ef074dd4d1c3df4a8f193f3650e188c4d4171bd1
  • Loading branch information
arhimondr authored and facebook-github-bot committed Jan 29, 2025
1 parent ce273fa commit a1b4ee7
Showing 1 changed file with 0 additions and 12 deletions.
12 changes: 0 additions & 12 deletions velox/exec/ExchangeQueue.h
Original file line number Diff line number Diff line change
Expand Up @@ -81,10 +81,6 @@ class SerializedPage {
/// for input.
class ExchangeQueue {
public:
#ifdef VELOX_ENABLE_BACKWARD_COMPATIBILITY
explicit ExchangeQueue() : ExchangeQueue(1, 0) {}
#endif

explicit ExchangeQueue(
int32_t numberOfConsumers,
uint64_t minOutputBatchBytes)
Expand Down Expand Up @@ -138,14 +134,6 @@ class ExchangeQueue {
ContinueFuture* future,
ContinuePromise* stalePromise);

#ifdef VELOX_ENABLE_BACKWARD_COMPATIBILITY
std::vector<std::unique_ptr<SerializedPage>>
dequeueLocked(uint32_t maxBytes, bool* atEnd, ContinueFuture* future) {
ContinuePromise stalePromise = ContinuePromise::makeEmpty();
return dequeueLocked(0, maxBytes, atEnd, future, &stalePromise);
}
#endif

/// Returns the total bytes held by SerializedPages in 'this'.
int64_t totalBytes() const {
return totalBytes_;
Expand Down

0 comments on commit a1b4ee7

Please sign in to comment.