может дать мне решение для многоуровневой агрегации потоковой структуризации. После поиска я обнаружил, что мы можем сделать это через flatMapGroup с помощью метода состояния.
Кто-нибудь может привести несколько примеров?