Как вставить нуль в массив данных столбца в ksql - PullRequest
0 голосов
/ 30 сентября 2019

Я создаю поток с типом данных Array. значение NULL приходит, поэтому обработайте это, я создаю другой поток поверх предыдущего потока и задаю регистр, как если бы его NULL ставил []. но это не работает.

Я пытался [], {}, [0], 0 в случаях.

CREATE STREAM stream1
(
id VARCHAR,
tags ARRAY<INT>, 
feed_id VARCHAR,
status INT,
updated_at VARCHAR
)
WITH (kafka_topic='origin_topic', value_format='JSON');

Create Stream stream2 AS 
select  
id AS id,
case when tags is NULL THEN [] END ELSE tags END as tags,
case when feed_id is NULL THEN '0' ELSE feed_id END as feed_id,
case when status is NULL THEN 0 ELSE status END as status,
case when updated_at is NULL THEN '0' ELSE updated_at END as 
updated_at
from stream1 PARTITION BY id;
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...