Function readValues

pj_runtime/tests/data_processor_service_test.cpp:53–62

)LUAU";

std::vector<double> readValues(DataEngine& engine, TopicId tid) {
  std::vector<double> out;
  const TopicStorage* storage = engine.getTopicStorage(tid);
  if (!storage) {
    return out;
  }
  auto cursor = rangeQuery(storage->sealedChunks(), 0, std::numeric_limits<Timestamp>::max());
  cursor.forEach([&](const SampleRow& row) { out.push_back(row.chunk->readNumericAsDouble(0, row.row_index)); });
  return out;
}

TEST(DataProcessorServiceTest, AppliesAbsoluteFilterAndMaterializesOutput) {
  DataEngine engine;