in harry-core/src/harry/visitors/RandomValidator.java [70:86]
private int validateRandomPartitions()
{
for (int i = 0; i < partitionCount && !Thread.currentThread().isInterrupted(); i++)
{
metricReporter.validateRandomQuery();
long modifier = this.modifier.incrementAndGet();
long pd = pdSelector.randomVisitedPd(tracker.maxStarted(), modifier, schemaSpec);
for (int j = 0; j < queries && !Thread.currentThread().isInterrupted(); j++)
{
Query query = querySelector.inflate(pdSelector.maxLtsFor(pd), j);
logger.logSelectQuery(j, query);
model.validate(query);
}
}
return partitionCount;
}