OperatorContext(int, PlanNodeId, String, DriverContext, Executor, MemoryTrackingContext) |  | 0% |  | 0% | 2 | 2 | 39 | 39 | 1 | 1 |
getOperatorStats() |  | 0% |  | 0% | 2 | 2 | 43 | 43 | 1 | 1 |
destroy() |  | 0% |  | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
requestMemoryRevoking() |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
updatePeakMemoryReservations() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
updateMemoryFuture(ListenableFuture, AtomicReference) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
setMemoryRevocationRequestListener(Runnable) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
recordBlocked(ListenableFuture) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
recordAddInput(OperationTimer, Page) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
recordGetOutput(OperationTimer, Page) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
runListener(Runnable) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
recordRawInputWithTiming(long, long, long) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
newLocalSystemMemoryContext(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
localUserMemoryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
localSystemMemoryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
localRevocableMemoryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
aggregateUserMemoryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
aggregateRevocableMemoryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
aggregateSystemMemoryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
updateTaskRevocableMemoryReservation() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordRawInput(long, long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
recordProcessedInput(long, long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
recordOutput(long, long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
setInfoSupplier(Supplier) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
moreMemoryAvailable() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordNullJoinBuildKeyCount(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordJoinBuildKeyCount(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordNullJoinProbeKeyCount(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordJoinProbeKeyCount(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordPhysicalWrittenData(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordAdditionalCpu(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
nanosBetween(long, long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
updateStats(RuntimeStats) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordFinish(OperationTimer) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
isWaitingForMemory() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isWaitingForRevocableMemory() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
accept(QueryContextVisitor, Object) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$updateMemoryFuture$0(SettableFuture) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSession() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isDone() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCurrentTotalMemoryReservationInBytes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getReservedRevocableBytes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
resetMemoryRevokingRequested() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getPhysicalWrittenDataSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOperatorId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPlanNodeId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOperatorType() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDriverContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRuntimeStats() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSpillContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isMemoryRevokingRequested() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getInputDataSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getInputPositions() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOutputDataSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOutputPositions() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOperatorMemoryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |