Method series

pj_datastore/src/reader.cpp:238–255

}

Expected<SeriesReader> DataReader::series(TopicId topic_id, std::size_t column_index) const {
  auto lock = engine_.lockEngine();
  const TopicStorage* storage = engine_.getTopicStorage(topic_id);
  if (storage == nullptr) {
    return PJ::unexpected(fmt::format("Topic {} not found", topic_id));
  }

  const std::vector<ColumnDescriptor> columns = columnsForTopic(engine_, *storage);
  if (column_index >= columns.size()) {
    return PJ::unexpected(fmt::format("Column {} not found in topic {}", column_index, topic_id));
  }

  if (!isSeriesValueType(columns[column_index].logical_type)) {
    return PJ::unexpected(fmt::format("Column {} in topic {} is not a numeric series", column_index, topic_id));
  }

  return SeriesReader(storage->sealedChunks(), column_index, storage->retentionFloor(), std::move(lock));
}

}  // namespace PJ