Kafka Streams и ksqlDB: данные в реальном времени [Митч Сеймур] (pdf) читать постранично, страница - 3

Avro............................................................................................................... 107
Анализ тональности........................................................................................................... 109
Сериализация данных Avro................................................................................................... 111
Сериализация формата Avro без сохранения схемы в реестре..................... 112
Сериализация формата Avro с сохранением схемы в реестре...................... 113
Добавление узла-приемника................................................................................................ 114
Запуск кода.................................................................................................................................... 115
Эмпирическая проверка......................................................................................................... 115
Заключение................................................................................................................................... 118
Глава 4. Обработка с сохранением состояния.................................................................... 119
Преимущества операций с сохранением состояния................................................. 120
Обзор методов............................................................................................................................. 121
Хранилища состояний............................................................................................................. 122
Общие характеристики..................................................................................................... 123
Постоянные хранилища и хранилища в оперативной памяти...................... 125
Список лидеров видеоигр...................................................................................................... 126
Настройка проекта.................................................................................................................... 128
Модели данных........................................................................................................................... 129
Добавление узлов-источников............................................................................................ 130
KStream..................................................................................................................................... 131
KTable........................................................................................................................................ 132
GlobalKTable........................................................................................................................... 133
Абстракции потока и таблиц................................................................................................. 135
Соединение................................................................................................................................... 135
Операторы соединения.................................................................................................... 137
Типы соединений................................................................................................................. 137

Оглавление  9
Совместное секционирование...................................................................................... 138
Интерфейс ValueJoiner...................................................................................................... 141
Соединение KStream и KTable........................................................................................ 143
Соединение KStream и GlobalKTable........................................................................... 145
Группировка записей................................................................................................................ 145
Группировка потоков......................................................................................................... 146
Группировка таблиц........................................................................................................... 147
Агрегирование............................................................................................................................ 147
Агрегирование потоков................................................................................................... 148
Агрегирование таблиц...................................................................................................... 151
Объединение фрагментов кода........................................................................................... 152
Интерактивные запросы......................................................................................................... 154
Материализованные хранилища................................................................................. 154
Доступ на чтение из хранилища состояний............................................................ 155
Запросы к неоконным хранилищам «ключ — значение»................................. 156
Локальные запросы............................................................................................................ 158
Удаленные запросы............................................................................................................ 159
Заключение................................................................................................................................... 166
Глава 5. Окна и время..................................................................................................................... 167
Приложение для контроля состояния пациентов...................................................... 168
Настройка проекта.................................................................................................................... 171
Модели данных........................................................................................................................... 171
Семантики времени.................................................................................................................. 172
Экстракторы отметок времени............................................................................................ 174
Встроенные экстракторы отметок времени........................................................... 175
Свои собственные экстракторы отметок времени.............................................. 177
Регистрация потоков со своими экстракторами отметок времени............. 178
Оконная обработка потоков................................................................................................. 179
Типы окон................................................................................................................................ 179
Выбор типа окна.................................................................................................................. 184
Оконное агрегирование.................................................................................................. 184
Вывод результатов оконной обработки.......................................................................... 186
Период отсрочки................................................................................................................. 188
Подавление............................................................................................................................