pub trait GroupsUdf:
Send
+ Sync
+ 'static {
// Required method
fn evaluate_on_groups<'a>(
&self,
inputs: &[Arc<dyn PhysicalExpr>],
df: &DataFrame,
groups: &'a GroupPositions,
state: &ExecutionState,
) -> PolarsResult<AggregationContext<'a>>;
}