pub trait AnonymousStreamingAgg: Send + Sync {
// Required methods
fn as_any(&self) -> &(dyn Any + 'static);
fn get_field(
&self,
input_schema: &Schema<DataType>,
fields: &[Field],
) -> Result<Field, PolarsError>;
}