Skip to main content

Module sink

Module sink 

Source
Expand description

Common sink implementations for push-based execution.

Sinks receive the output from pipelines and handle the final results.

Structsยง

CollectorSink
Collects all chunks for final query result output.
CountingSink
Counting sink that just counts rows without storing data.
LimitingSink
Limiting sink that stops after collecting N rows.
MaterializingSink
Materializing sink that buffers all data in memory.
NullSink
Null sink that discards all data.