Всем привет. Вопрос про Ksql-server. Есть абстрактный топик my_test. Задача

Question

Всем привет. Вопрос про Ksql-server. Есть абстрактный топик my_test. Задача

- построить ktable с количеством записей по дням, опираясь на ROWTIME. Для этого пришлось сделать:
1)Create stream s_my_test with (kafka_topic='my_test', value_format='avro') ;
2)Create stream s_my_test_dt with (value_format='avro') as select timestamptostring(ROWTIME, 'yyy-MM-dd') as dt from s_mon_test;
3)create table t_my_test_dt as select dt, count(*) as cnt from s_my_test_dt group by dt;
В связи с этим два вопроса:
1) можно как-то в пункт 3 прийти покороче, без 1,2?
3)почему запрос select cnt, dt from t_my_test_dt; выводит мне вместо одной последней записи целую портянку строк, с cnt=n+1, даже при отсутствии записи в исходный топик?

#kafka #russian #software

0

09.04.2020

2 ответов

14 просмотров

Vik Gamov

Господи, вот уж привычка дурная с оракла прификсы делать для таблиц t_

0

09.04.2020

Vik Gamov · Accepted Answer

Vik Gamov

а какая версия?

0

09.04.2020

52 похожих чатов

Всем привет. Вопрос про Ksql-server. Есть абстрактный топик my_test. Задача

2 ответов

Похожие вопросы