Method OperatorTraceScan

bolt/exec/OperatorTraceScan.cpp:36–53

namespace bytedance::bolt::exec::trace {

OperatorTraceScan::OperatorTraceScan(
    int32_t operatorId,
    DriverCtx* driverCtx,
    const std::shared_ptr<const core::TraceScanNode>& traceScanNode)
    : SourceOperator(
          driverCtx,
          traceScanNode->outputType(),
          operatorId,
          traceScanNode->id(),
          "OperatorTraceScan") {
  traceReader_ = std::make_unique<OperatorTraceInputReader>(
      getOpTraceDirectory(
          traceScanNode->traceDir(),
          traceScanNode->pipelineId(),
          traceScanNode->driverIds().at(driverCtx->driverId)),
      traceScanNode->outputType(),
      memory::MemoryManager::getInstance()->tracePool());
}

RowVectorPtr OperatorTraceScan::getOutput() {
  RowVectorPtr batch;