Append one row (ts, value) to an existing scalar topic and commit.
| 1496 | |
| 1497 | // Append one row (ts, value) to an existing scalar topic and commit. |
| 1498 | static void appendRow(DataEngine& engine, PJ::TopicId topic_id, PJ::Timestamp ts, double value) { |
| 1499 | DataWriter writer = engine.createWriter(); |
| 1500 | auto s = writer.beginRow(topic_id, ts); |
| 1501 | (void)s; |
| 1502 | writer.set(topic_id, 0, value); |
| 1503 | auto s2 = writer.finishRow(topic_id); |
| 1504 | (void)s2; |
| 1505 | engine.commitChunks(writer.flushAll()); |
| 1506 | } |
| 1507 | |
| 1508 | TEST(DerivedEngineTest, SisoLateInputCommitTriggersFullRecompute) { |
| 1509 | DataEngine engine; |
no test coverage detected