in harry-core/src/harry/visitors/RecentValidator.java [62:84]
private int validateRecentPartitions()
{
long pos = pdSelector.maxPosition(clock.peek());
int maxPartitions = partitionCount;
while (pos >= 0 && maxPartitions > 0 && !Thread.currentThread().isInterrupted())
{
long visitLts = pdSelector.minLtsAt(pos);
for (int i = 0; i < queries; i++)
{
metricReporter.validateRandomQuery();
Query query = querySelector.inflate(visitLts, i);
// TODO: add pd skipping from shrinker here, too
log(i, query);
model.validate(query);
}
pos--;
maxPartitions--;
}
return partitionCount - maxPartitions;
}