Возвращать имена столбцов в KSQL в KTable - PullRequest
0 голосов
/ 17 января 2019

Я использую Kafka KSQL REST API для выполнения запроса (/query), и внутри ответа я могу получить доступ к результирующим столбцам с помощью этого API: https://docs.confluent.io/current/ksql/docs/developer-guide/api.html#run-a-query-and-stream-back-the-output

row.columns[i] (?) – The value contained in a single column for the row. The value type depends on the type of the column.

Так что я могу получить доступ к значениям столбцов, а не к именам столбцов.

Можно ли как-нибудь получить доступ к именам столбцов, или мне нужно вручную проанализировать запрос KSQL, чтобы получить оттуда имена столбцов?

Например, вместо [1524760769983,"1",1524760769747,"alice","home"] Я хотел бы получить {"columnA":1524760769983,"columnB":"1","columnC":1524760769747,"columnD":"alice","columnE":"home"]

1 Ответ

0 голосов
/ 17 января 2019

Я не думаю, что это возможно в настоящее время.Я зарегистрировал # 2364 как запрос на расширение, так как вижу, что это было бы полезно.

...