Нин Ван , Джош Фишер - Грокаем стриминг
Название: | Грокаем стриминг | |
Автор: | Нин Ван , Джош Фишер | |
Жанр: | Базы данных, Учебники и самоучители по компьютеру | |
Изадано в серии: | неизвестно | |
Издательство: | неизвестно | |
Год издания: | - | |
ISBN: | неизвестно | |
Отзывы: | Комментировать | |
Рейтинг: | ||
Поделись книгой с друзьями! Помощь сайту: донат на оплату сервера |
Краткое содержание книги "Грокаем стриминг"
Cтриминговые системы позволяют сократить до минимума время между событием и обработкой информации, чтобы вы получали результаты в реальном времени. В приложениях для финансовой сферы, в вопросах безопасности и IoT важна каждая миллисекунда, поэтому без стриминговых систем не обойтись. А еще — это модно и приносит деньги ;) ! Неслучайно специалисты в Spark, Heron и Kafka так востребованы.
Наконец, вы можете познакомиться с созданием стриминговых приложений и обработкой событий в реальном времени не продираясь через технические подробности конкретных фреймворков, головоломные термины и сложные формулировки. Простой язык и яркие примеры позволят вам познакомиться с базовыми концепциями, а чтобы усвоить описанные идеи и приемы, вы построите собственную простую стриминговую программу с нуля.
От читателя не требуется опыт работы со стриминговыми системами. Примеры написаны на языке Java.
Читаем онлайн "Грокаем стриминг". [Страница - 4]
Коммуникации между компонентами по каналам . . . . . . . . . . . . . . . . . . . . . . . . .
Несколько каналов . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Объединение потока в агрегаторе оценок . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Объединение потоков в ядре . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Краткий обзор разновидности объединения потоков — соединения . . . .
Система в целом . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Графы и стриминговые задания . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Примеры систем . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Итоги . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Упражнения . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
114
115
116
117
118
119
120
121
122
123
124
Глава 5. Семантика доставки . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 125
Требования к задержке в системе обнаружения мошеннических
действий . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 126
Возвращаемся к заданию обнаружения мошеннических действий . . . . . . . 127
О точности . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 128
Частичный результат . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 129
Новое стриминговое задание для контроля за использованием
системы . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 130
Новое задание контроля использования системы . . . . . . . . . . . . . . . . . . . . . . . . 131
Требования к заданию контроля . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 132
Новые концепции: количество доставок и обработок . . . . . . . . . . . . . . . . . . . . . 133
Новая концепция: семантика доставки . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 134
Выбор семантики . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 135
«Не более одного» . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 136
Задание обнаружения мошеннических действий . . . . . . . . . . . . . . . . . . . . . . . . . 137
«Не менее одного» . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 138
«Не менее одного» с подтверждением . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 139
Отслеживание событий . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 140
Управление сбоями при обработке событий . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 141
Раннее обнаружение потерянных событий . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 142
Код подтверждения в компонентах . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 143
Новая концепция: контрольные точки . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 143
Новая концепция: состояние . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 145
Контрольные точки в задании контроля за использованием системы
для семантики «не менее одного» . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 145
Контрольные точки и функции управления состоянием . . . . . . . . . . . . . . . . . . 147
Код управления состоянием в компоненте источника транзакций . . . . . . . . 148
Оглавление 9
Ровно один или фактически один? . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Вспомогательная концепция: идемпотентные операции . . . . . . . . . . . . . . . . . .
Наконец, «ровно один» . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Код управления состоянием в компоненте анализатора
использования системы . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Повторное сравнение семантик доставки . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
Итоги . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . --">