| 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 |