maedhroz commented on code in PR #24:
URL: https://github.com/apache/cassandra-harry/pull/24#discussion_r1417705068
##########
harry-core/src/harry/visitors/MutatingVisitor.java:
##########
@@ -66,17 +67,52 @@ public MutatingVisitor(Run run,
super(run, visitExecutor);
}
+ public static class LtsTrackingVisitExecutor extends MutatingVisitExecutor
+ {
+ public LtsTrackingVisitExecutor(OpSelectors.DescriptorSelector
descriptorSelector, DataTracker tracker, SystemUnderTest sut, SchemaSpec
schema, OperationExecutor rowVisitor, SystemUnderTest.ConsistencyLevel
consistencyLevel)
+ {
+ super(descriptorSelector, tracker, sut, schema, rowVisitor,
consistencyLevel);
+ }
+
+ @Override
+ public void afterLts(long lts, long pd)
+ {
+ if (hadVisibleVisit)
+ {
+ StringBuilder sb = new StringBuilder();
+ sb.append("UPDATE
").append(schema.keyspace).append(".").append(schema.table)
+ .append(" SET visited_lts = visited_lts +
[").append(lts).append("] ")
Review Comment:
So we're guaranteed the schema has `visited_lts` here?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
