KSQL Array Of Object - PullRequest
Новая
       15

KSQL Array Of Object

1 голос
/ 03 мая 2019

Я пытаюсь получить данные из Object Array с помощью ksql. Любой, кто может мне помочь :)

У меня есть JSON-сообщение 

"Total": [
        {
          "TotalType": "Standard",
          "TotalAmount": 15.99
        }

Я пишу это, но это не сработает 

create stream test2 (Total Array<STRUCT>< <TotalAmount Double>) with(KAFKA_TOPIC='hermes__output',VALUE_FORMAT='JSON');


create stream test2 (Total[0] STRUCT<TotalAmount Double>) with(KAFKA_TOPIC='hermes__output',VALUE_FORMAT='JSON');

1010 * ТНХ *

...