risingwave_
frontend
2.2.0-alpha
In risingwave_
frontend::
optimizer::
plan_
node::
logical_
agg
risingwave_frontend
::
optimizer
::
plan_node
::
logical_agg
Function
new_stream_simple_agg
Copy item path
source
fn new_stream_simple_agg( core:
Agg
<
PlanRef
>, must_output_per_barrier:
bool
, ) ->
StreamSimpleAgg