Вложенный вывод Flink

Question

Я обрабатываю поток Kafka с помощью Flink SQL, где каждое сообщение извлекается из Kafka, обрабатывается с помощью flink sql и отправляется обратно в kafka. Я хотел, чтобы вложенные выходные данные были плоскими, а выходные - вложенными. Скажем, например, мой ввод

{'StudentName':'ABC','StudentAge':33}

и хотите выводить как

{'Student':{'Name':'ABC','Age':33}}

Я попытался найти здесь и несколько похожих ссылок, но не смог найти. Возможно ли это сделать с помощью Apache Flink SQL API? При необходимости может использовать пользовательские функции, но не хочет этого.

Answer 1

Вы можете попробовать что-то вроде этого:

SELECT 
  MAP ['Student', MAP ['Name', StudentName, 'Age', StudentAge]] 
FROM 
  students;

Я нашел здесь функцию MAP , но мне пришлось поэкспериментировать в клиенте SQL , чтобы выяснить синтаксис.