SpoolingOutputBuffer(TaskId, String, OutputBuffers, StateMachine, TempStorage, long, ListeningExecutorService, FinalizerService) |  | 0% |  | 0% | 2 | 2 | 30 | 30 | 1 | 1 |
acknowledgePagesFromStorage(long) |  | 0% |  | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
getPagesFromStorage(ImmutableList.Builder, Iterator, TempStorageHandle, SpoolingOutputBuffer.GetTracker) |  | 0% |  | 0% | 5 | 5 | 22 | 22 | 1 | 1 |
processRead(long, long) |  | 0% |  | 0% | 6 | 6 | 13 | 13 | 1 | 1 |
enqueue(Lifespan, List) |  | 0% |  | 0% | 4 | 4 | 21 | 21 | 1 | 1 |
acknowledge(OutputBuffers.OutputBufferId, long) |  | 0% |  | 0% | 7 | 7 | 13 | 13 | 1 | 1 |
acknowledgePagesFromMemory(long, long) |  | 0% |  | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
flush() |  | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
get(OutputBuffers.OutputBufferId, long, long) |  | 0% |  | 0% | 8 | 8 | 12 | 12 | 1 | 1 |
getPagesFromMemory(long, SpoolingOutputBuffer.GetTracker) |  | 0% |  | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
setNoMorePages() |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
lambda$processRead$1(SpoolingOutputBuffer.GetTracker, long, long, List) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
setOutputBuffers(OutputBuffers) |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
close() |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
getInfo() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
getPagesFromStorage(long, SpoolingOutputBuffer.GetTracker) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
destroy() |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
lambda$processRead$3(long, Exception) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$processRead$2(long, List) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
processPendingRead(SpoolingOutputBuffer.PendingRead) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
checkFlushComplete() |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
abort(OutputBuffers.OutputBufferId) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
enqueue(Lifespan, int, List) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$flush$0(List) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
isOverutilized() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
isFinished() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
getUtilization() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
fail() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$fail$7(BufferState) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$destroy$6(BufferState) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getPagesFromStorage$5(ImmutableList.Builder, Iterator, SpoolingOutputBuffer.GetTracker, TempStorageHandle) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getPagesFromStorage$4(Iterator, SpoolingOutputBuffer.GetTracker, TempStorageHandle) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPagesSize(Collection) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPagesRows(Collection) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
addStateChangeListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getPeakMemoryUsage() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isFull() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isFinishedForLifespan(Lifespan) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setNoMorePagesForLifespan(Lifespan) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
registerLifespanCompletionCallback(Consumer) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |