Method serialize

bolt/exec/OperatorTraceWriter.cpp:157–169

static

// static
std::unique_ptr<folly::IOBuf> OperatorTraceSplitWriter::serialize(
    const std::string& split) {
  const uint32_t length = split.length();
  const uint32_t crc32 = folly::crc32(
      reinterpret_cast<const uint8_t*>(split.data()), split.size());
  auto ioBuf =
      folly::IOBuf::create(sizeof(length) + split.size() + sizeof(crc32));
  folly::io::Appender appender(ioBuf.get(), 0);
  appender.writeLE(length);
  appender.push(reinterpret_cast<const uint8_t*>(split.data()), length);
  appender.writeLE(crc32);
  return ioBuf;
}

void OperatorTraceSplitWriter::writeSummary() const {
  const auto summaryFilePath = getOpTraceSummaryFilePath(traceDir_);