В операторе создания потока возникла проблема с пробелами в ключах. Например:
CREATE STREAM test (
Date Time VARCHAR,
) WITH (KAFKA_TOPIC='test', VALUE_FORMAT='JSON');
Как мне обрабатывать пробелы в именах ключей?
Я пробовал:
'Date Time' VARCHAR,
и
[Date Time] VARCHAR,
Но оба дают мне постороннюю ошибку ввода.
[Обновить] Я изменил имя ключа выше с Полное имя (произвольно) на Дата и время (актуально). Также добавлено json-сообщение из источника ниже, но удалено большинство пар ключ-значение и скрыто большинство значений с xxx .
{
"beat": {
"hostname": "xxx",
"version": "xxx"
},
"Date Time": "2019-05-21T22:18:06.000Z",
"host": {
"name": "xxx"
},
"input": {
"type": "xxx"
},
"fields": {
"env": "xxx"
}
}