Method OperatorTraceInputReader

bolt/exec/OperatorTraceReader.cpp:38–49

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

OperatorTraceInputReader::OperatorTraceInputReader(
    std::string traceDir,
    RowTypePtr dataType,
    memory::MemoryPool* pool)
    : traceDir_(std::move(traceDir)),
      fs_(filesystems::getFileSystem(traceDir_, nullptr)),
      dataType_(std::move(dataType)),
      pool_(pool),
      serde_(getNamedVectorSerde(VectorSerde::Kind::kPresto)),
      inputStream_(getInputStream()) {
  BOLT_CHECK_NOT_NULL(dataType_);
}

bool OperatorTraceInputReader::read(RowVectorPtr& batch) const {
  if (inputStream_ == nullptr) {