Для чего необходима директива EMIT CHANGES в KSQL?
Подскажите, пожалуйста, для чего в запросах KSQL прописывают EMIT CHANGES. Например, в запросе:
CREATE STREAM pageviews_intro AS
SELECT * FROM pageviews
WHERE pageid < 'Page_20'
EMIT CHANGES;
P.S. Да, гуглил