David Bryson
09/18/2023, 11:35 PMclass FlatAggregateTable(object):
"""
A table that performs flatAggregate on a :class:`~pyflink.table.Table`, a
:class:`~pyflink.table.GroupedTable` or a :class:`~pyflink.table.WindowGroupedTable`
"""
But when I look at the WindowGroupedTable
source, it doesn't seem to have the flat_aggregate
call implemented, only aggregate
. Is it possible to perform a table aggregation over a windowed table?