```mermaid
flowchart BT
daft_local_execution::intermediate_ops::intermediate_op::IntermediateNode0["ProjectOperator
rows received =  1
rows emitted =  1
CPU Time = 0.01ms
"]
daft_local_execution::sinks::streaming_sink::StreamingSinkNode1["Limit
rows received =  1
rows emitted =  1
CPU Time = 0.00ms
"]
daft_local_execution::sinks::blocking_sink::BlockingSinkNode2["AggregateSink
rows received =  22,368
rows emitted =  1
CPU Time = 46.96ms
"]
daft_local_execution::sources::source::SourceNode3["ScanTask

rows emitted =  22,368
bytes read = 6.78 GiB
"]
daft_local_execution::sources::source::SourceNode3 --> daft_local_execution::sinks::blocking_sink::BlockingSinkNode2
daft_local_execution::sinks::blocking_sink::BlockingSinkNode2 --> daft_local_execution::sinks::streaming_sink::StreamingSinkNode1
daft_local_execution::sinks::streaming_sink::StreamingSinkNode1 --> daft_local_execution::intermediate_ops::intermediate_op::IntermediateNode0

```