return messageQueue.isEmpty() && entryQueue.isEmpty() && isDone.get()&& outstandingReadsRequests.get() >= 1; | return messageQueue.isEmpty() && isDone && outstandingReadsRequests.get() >= 1 && splitSize <= entriesProcessed; | messageQueue.isEmpty() && entryQueue.isEmpty() && isDone.get()&& outstandingReadsRequests.get() >= 1 | messageQueue.isEmpty() && isDone && outstandingReadsRequests.get() >= 1 && splitSize <= entriesProcessed | pulsar | 32d6334d10e578ea1adff93139ca8efca4afe277 | org.apache.pulsar.sql.presto.PulsarRecordCursor.ReadEntries | | | TCIVar | isDone |
---|
v1 | messageQueue.isEmpty() |
---|
v2 | outstandingReadsRequests.get() >= 1 |
---|
| | TCIVar | isDone |
---|
v1 | messageQueue.isEmpty() |
---|
v2 | outstandingReadsRequests.get() >= 1 |
---|
| Uses | False |