Как K SQL обновляет записи таблицы?

Question

Я прочитал эту статью https://docs.confluent.io/current/ksql/docs/developer-guide/aggregate-streaming-data.html. И кажется, я не понимаю одну вещь.

Например, COUNT K SQL обновляет записи при поступлении новых сообщений. Это означает, что K SQL знает, как найти определенную запись, чтобы обновить ее. Для этого есть запрос:

CREATE TABLE pageviews_per_region AS
  SELECT regionid,
         COUNT(*)
  FROM pageviews
  GROUP BY regionid
  EMIT CHANGES;

Это имя столбца в предложении GROUP BY, которое помогает K SQL найти определенную запись?

Answer 1

Это означает, что K SQL знает, как найти определенную запись, чтобы обновить ее

Да, поскольку все потоки и таблицы имеют собственную схему, их поля называются .

Предложение GROUP BY работает так же, как и любой аналогичный запрос SQL, в котором он определяет агрегированную проекцию, а COUNT - агрегатная функция по проекции