Crate flows_datafusion

Crate flows_datafusion 

Source

Functionsยง

avg
avg_column
A block that outputs the average of all values in a given column.
concat_batches
A block that concatenates input batches into a single output batch.
count_rows
A block that outputs row counts of input record batches.
max_array
max_column
A block that outputs the maximum of the values in a given column.
min_array
min_column
A block that outputs the minimum of the values in a given column.
project_columns
A block that projects columns from input batches to output batches.
slice_rows
A block that applies offsets/limits to batches of rows.
sum_array
sum_column
A block that outputs the sum of the values in a given column.