Как написать SQL для расчета на основе добавочного окна пакетной таблицы

Мое требование состоит в том, чтобы вычислить на основе окна добавочного размера для пакетной таблицы.

Например, первое окно имеет 1 строку, второе окно имеет 2 строки (включая 1 строку из 1-го окна и новую строку), затем 3 строки в 3-м окне (включая 2 строки из 2-го окна и новую строку) , и так далее.

Например:

Исходная таблица:

дата и время | идентификатор продукта | цена |

3-1 | p1 | 10 |

3-2 | p1 | 20 |

3-3 | p1 | 30 |

3-4 | p1 | 40 |

Таблица результатов:

дата и время | идентификатор продукта | средний|

3-1 | p1 | 10/1 |

3-2 | p1 | (10+20)/2 |

3-3 | p1 | (10+20+30)/3 |

3-4 | p1 | (10+20+30+40)/4 |

Я пытаюсь найти способ реализовать это требование с помощью Sql, мне кажется, что действие OVER может это сделать, но еще не реализовано в flink, поэтому мне нужен альтернативный способ.

Кстати:

Я попытался использовать окно TUMBLE на 1 день и сохранить предыдущее значение в определяемом пользователем объекте агрегации, но не удалось, так как объект агрегации будет повторно использоваться всеми продуктами, а не отдельными объектами для каждого продукта