Module sink

Module sink 

Source
Expand description

Execution plan for writing data to DataSinks

Structs§

DataSinkExec
Execution plan for writing record batches to a DataSink

Traits§

DataSink
DataSink implements writing streams of [RecordBatch]es to user defined destinations.

Functions§

make_count_batch 🔒
Create a output record batch with a count
make_count_schema 🔒