Method SetUp

bolt/exec/tests/ExchangeClientTest.cpp:51–60

  }

  void SetUp() override {
    executor_ = std::make_unique<folly::CPUThreadPoolExecutor>(16);
    exec::ExchangeSource::factories().clear();
    exec::ExchangeSource::registerFactory(test::createLocalExchangeSource);
    if (!isRegisteredVectorSerde()) {
      bolt::serializer::presto::PrestoVectorSerde::registerVectorSerde();
    }

    bufferManager_ = OutputBufferManager::getInstance().lock();
  }

  std::unique_ptr<SerializedPage> toSerializedPage(const RowVectorPtr& vector) {
    auto data = std::make_unique<VectorStreamGroup>(pool());