Method beginRow

pj_datastore/src/writer.cpp:263–273

// ---------------------------------------------------------------------------

PJ::Status DataWriter::beginRow(TopicId topic_id, Timestamp t) {
  auto* storage = impl_->engine.getTopicStorage(topic_id);
  if (storage == nullptr) {
    return PJ::unexpected(fmt::format("Topic {} not found", topic_id));
  }
  auto& builder = getOrCreateBuilder(topic_id);
  // Out-of-order timestamps are accepted (multi-publisher topics interleave
  // regressing stamps); the builder sorts rows at seal.
  builder.beginRow(t);
  return PJ::okStatus();
}

PJ::Status DataWriter::finishRow(PJ::TopicId topic_id) {
  auto it = impl_->builders.find(topic_id);