// remain
while (docIter.hasNext()) {
TemporalDocument doc = docIter.next();
int docNumber = count.incrementAndGet();
long docTime = doc.timeStamp();
// special case for first document
if (docNumber == 1) {
curSSpaceStartTime.set(docTime);
startBarrier.set(true);