| 55 | } |
| 56 | |
| 57 | void SetUp() override { |
| 58 | pool_ = bytedance::bolt::memory::memoryManager()->addLeafPool(); |
| 59 | bufferManager_ = OutputBufferManager::getInstance().lock(); |
| 60 | if (!isRegisteredVectorSerde()) { |
| 61 | bytedance::bolt::serializer::presto::PrestoVectorSerde:: |
| 62 | registerVectorSerde(); |
| 63 | bufferManager_->setListenerFactory([]() { |
| 64 | return std::make_unique< |
| 65 | serializer::presto::PrestoOutputStreamListener>(); |
| 66 | }); |
| 67 | } |
| 68 | } |
| 69 | |
| 70 | std::shared_ptr<Task> initializeTask( |
| 71 | const std::string& taskId, |
nothing calls this directly
no test coverage detected