KSQL - цикл по массиву JSON

Question

У меня есть данные темы kafka со следующей структурой:

    { property1:value1, 
      property2:value2, 
      property3: [    
       {
        subprop1:subval11,
        subprop2:subval12,
        subprop3:subval13    
       },    
       {
         subprop1:subval21,
         subprop2:subval22,
         subprop3:subval23
        },
        ...
     ] 
   }

в документации по KSQL, однако я могу объявить поток или таблицу с форматом ARRAY для столбца, однако при создании потокаМне нужно перебрать этот массив.

Мой вывод KSQL должен быть:

PropertyID1 |subprop1 | subprop2 | subprop3
Value1      |subval11 | subval12 | subval13
Value1      |subval21 | subval22 | subval23

, так как должна выглядеть моя функция создания потока?

Пока у меня есть:

CREATE STREAM testarrayjsonstream \
  (property1 VARCHAR, \
   property3 ARRAY) \
  WITH (KAFKA_TOPIC='topic1', \
        VALUE_FORMAT='AVRO');

тогда я могу сделать:

Create Stream testarrayjsontopic as \
select property1,property3[0]->subprop1 from testarrayjsonstream

, но это дает мне только первый элемент массива - мне нужно пройти через все элементы массива.какие-нибудь указатели?

Answer 1

KSQL в настоящее время не поддерживает это.Вы можете проголосовать или прокомментировать вопрос здесь .