Я использую Flink SQL для обработки пакета.Как я могу получить топ-n записи для каждой группы, используя FLINK SQL?
Flink SQL (до версии 1.7) не предоставляет встроенную функцию агрегирования для top-n.
Вы можете реализовать пользовательскую функцию агрегирования для поддержки вашего варианта использования.