Method MergeExchangeSource

bolt/exec/MergeSource.cpp:208–224

class MergeExchangeSource : public MergeSource {
 public:
  MergeExchangeSource(
      MergeExchange* mergeExchange,
      const std::string& taskId,
      int destination,
      int64_t maxQueuedBytes,
      memory::MemoryPool* pool,
      folly::Executor* executor)
      : mergeExchange_(mergeExchange),
        client_(std::make_shared<ExchangeClient>(
            mergeExchange->taskId(),
            destination,
            maxQueuedBytes,
            pool,
            executor)) {
    client_->addRemoteTaskId(taskId);
    client_->noMoreRemoteTasks();
  }

  void start() override {}