Для чего необходима директива EMIT CHANGES в KSQL?

Подскажите, пожалуйста, для чего в запросах KSQL прописывают EMIT CHANGES. Например, в запросе:

CREATE STREAM pageviews_intro AS
SELECT * FROM pageviews
WHERE pageid < 'Page_20'
EMIT CHANGES;

P.S. Да, гуглил


Ответы (0 шт):