Вопрос в руководстве разработчика для Kafka DSL API

Question

У меня возник вопрос при прохождении через это удивительное руководство https://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html

Мой вопрос находится в разделе «Пример семантики для агрегирования таблиц».В частности, посмотрите на таблицу в этом разделе, на отметке времени 4, но какой механизм для агрегатора выполняет «(E, 5 - 5)».

Меня сбивает с толку то, что ключ уже преобразован изимя ("Алиса") для региона ("A") на этапе группировки.Как «groupedTable» все еще может определять исходный ключ в совокупности и выполнять вычитание?

Заранее спасибо.

Answer 1

Здесь есть два механизма:

1. базовое хранилище может получить старое значение для ключа из хранилища, прежде чем оно поместит новое значение в хранилище
2. при необходимости вышестоящий оператор, размещающий базовое хранилище, отправит новое и старое значение последующему оператору