Потоковая обработка данных с Apache Flink : основы разработки потоковых приложений

Содержание книги "Потоковая обработка данных с Apache Flink : основы разработки потоковых приложений"

Предисловие
От издательства
Благодарности
Об авторах
Колофон
Глава 1. Введение в потоковую обработку с учетом состояния
1.1. Традиционные инфраструктуры данных
1.2. Обработка потоков с учетом состояния
1.3. Эволюция потоковой обработки с открытым исходным кодом
1.4. Обзорное знакомство с Flink
1.5. Заключение
Глава 2. Основы потоковой обработки
2.1. Введение в потоковое программирование
2.2. Параллельная обработка потоков
2.3. Семантика времени
2.4. Модели состояния и согласованности
2.5. Заключение
Глава 3. Архитектура Apache Flink
3.1. Архитектура системы
3.2. Передача данных во Flink
3.3. Обработка на основе времени события
3.4. Управление состоянием
3.5. Контрольные точки, точки сохранения и восстановление состояния
3.6. Заключение
Глава 4. Настройка рабочей среды для Apache Flink
4.1. Необходимое ПО
4.2. Запуск и отладка приложений Flink в среде IDE
4.3. Развертывание проекта Flink для сборщика Maven
4.4. Заключение
Глава 5. API DataStream (v1.7)
5.1. Hello, Flink!
5.2. Преобразования
5.3. Настройка параллельной обработки
5.4. Типы
5.5. Определение ключей и полей ссылок
5.6. Реализация функций
5.7. Добавление внешних и Flink-зависимостей
5.8. Заключение
Глава 6. Операторы на основе времени и оконные операторы
6.1. Настройка показателей времени
6.2. Функции процесса
6.3. Оконные операторы
6.4. Объединение потоков по времени
6.5. Обработка опоздавших данных
6.6. Заключение
Глава 7. Операторы и приложения с учетом состояния
7.1. Реализация функций с сохранением состояния
7.2. Включение восстановления после сбоя для приложений с учетом состояния
7.3. Обеспечение работоспособности приложений с учетом состояния
7.4. Производительность и надежность приложений с учетом состояния
7.5. Развитие приложений с учетом состояния
7.6. Запрашиваемое состояние
7.7. Заключение
Глава 8. Чтение и запись при работе с внешними системами
8.1. Гарантии согласованности приложений
8.2. Соединители Apache Flink
8.3. Реализация пользовательской исходной функции
8.4. Реализация пользовательской функции приемника
8.5. Асинхронный доступ к внешним системам
8.6. Заключение
Глава 9. Настройка Flink для потоковых приложений
9.1. Режимы развертывания
9.2. Режим высокой доступности
9.3. Интеграция с компонентами Hadoop
9.4. Конфигурация файловой системы
9.5. Конфигурация системы
9.6. Заключение
Глава 10. Работа с Flink и потоковыми приложениями
10.1. Запуск и управление потоковыми приложениями
10.2. Управление планированием задач
10.3. Настройка контрольных точек и восстановления
10.4. Мониторинг кластеров и приложений Flink
10.5. Настройка журналирования
10.6. Заключение
Глава 11. Что дальше?
11.1. Остальная часть экосистемы Flink
11.2. Присоединяйтесь к сообществу Flink
Предметный указатель