Подлинные принципы Flink, фактические боевые и оптимизация производительности
Вес товара: ~0.7 кг. Указан усредненный вес, который может отличаться от фактического. Не включен в цену, оплачивается при получении.
Описание товара
| Принцип Flink | ||
 | Ценообразование | 79.00 |
| Издатель | Machinery Industry Press | |
| Версия | 1 | |
| Опубликованная дата | Май 2019 | |
| формат | 16 | |
| автор | Чжан Либегинг | |
| Украсить | Платформный порядок | |
| Количество страниц | ||
| Число слов | ||
| Кодирование ISBN | 9787111623533 | |
| масса | ||
Это фактическая боевая деятельность, может направлять читателей для освоения Flink и быстро завершить передовые работы.Автор является глубоким экспертом в этой области.В книге насчитывается 10 глав, логически разделенные на три части: *Часть (Глава 1 ~ 2) в основном представляет основную концепцию, характеристики, сценарии применения, базовую архитектуру, конструкцию и конфигурацию среды разработки и исходный код компиляции исходного кода.Часть 2 (глава 3 ~ 9) объясняет парадигму программирования подробно, функции, сценарии применения и методов использования различных интерфейсов программирования, а также принципы и использование основных модулей и компонентов.Часть III (глава 1) фокусируется на наблюдении и оптимизации ящика, настройки параметров и оптимизации анти -давления, контрольной точки и памяти.
"Предисловие
Глава 1 Apache Flink Введение 1
1.1 Что такое Apache Flink 1
1.2 Эволюция архитектуры данных 2
1.2.1 Традиционная инфраструктура данных 3
1.2.2 Архитектура больших данных 4
1.2.3 Архитектура расчета потока состояния 5
1.2.4 Почему Flink 6
1.3 Сценарии приложений Flink 8
1.4 Flink Basic Architecture 10
1.4.1 Основной стек компонентов 10
1.4.2 Основная архитектурная диаграмма 11
1.5 Сводка этой главы 13
Глава 2 Подготовка среды 14
2.1 Введение операционной среды 14
2.2 Шаблон проекта Flink 15
2.2.1 Шаблон проекта на основе Java на основе Java 15
2.2.2 Шаблон проекта на основе Scala 18
2.3 Конфигурация среды разработки Flink 20
2.3.1 Скачать Intellij Idea IDE 21
2.3.2 Установить плагины Scala 21
2.3.3 Import Flink Code Application 22
2.3.4 Конфигурация проекта 22
2.4 запустить Scala Repl 24
2.4.1 Экологическая поддержка 24
2.4.2 Программа работы 24
2.5 Компиляция исходного кода Flink 25
2.6 Резюме этой главы 26
Глава 3 Модель программирования Flink 27
3.1 Тип набора данных 27
3.2 Интерфейс программирования Flink 29
3.3 Структура программы Flink 30
3.4 Тип данных Flink 37
3.4.1 Поддержка типа данных 37
3.4.2 40
3.5 Резюме этой главы 43
Глава 4 DataStream API Введение и использование 44
4.1 Модель программирования DataStream 44
4.1.1 Ввод данных данных 45
4.1.2 Операция преобразования данных DataSteam 49
4.1.3 59
4.2 Time Concept и Watermark 61
4.2.1 Тип концепции времени 61
4.2.2 Eventtime и Watermark 63
4.3 Расчет окна Windows 69
4.3.1 ПРИСУДАРЖАТЕЛЬ WINDOWS 70
4.3.2 Функция Windows 77
4.3.3 Триггера запуска окна 83
4.3.4 Устройство удаления данных Exictors 87
4.3.5 Задержка обработки данных 88
4.3.6 Непрерывное расчет окна 89
4.3.7 Multi -Creaming Merge Windows 90
4.4 95
4.4.1 95
4.4.2 Слоты группы ресурсов 96
4.5 Асинхронная ввод/асинхронная операция 97
4.6 Резюме этой главы 98
Глава 5 Управление статусом Flink и терпимость разлома 100
5.1 Расчет статуса 100
5.2 Контрольные точки и точки сохранения 109
5.2.1 Механизм контрольно -пропускных пунктов. 109
5.2.2 Механизм сохранения точек 111
5.3 Менеджер статуса 114
5.3.1 Категория Statebackend 114
5.3.2 Конфигурация диспетчера состояния 116
5.4 Состояние запроса 118
5.5 Сводка этой главы 123
Глава 6 Введение и использование API набора данных 124
6.1 API набора данных 124
6.1.1 Экземпляр приложения 125
6.1.2 Доступ к данным данных 126
6.1.3 Операция преобразования наборов данных 128
6.1.4 134
6.2 Расчет итерации 136
6.2.1 Полная итерация 136
6.2.2 Увеличьте итерацию 137
6.3 Переменные трансляции и распределенный кэш 139
6.3.1 вещательные переменные 139
6.3.2 Распределенный кеш 140
6.4 Семантическая аннотация 141
6.4.1 Переадресованные примечание. 141
6.4.2 Примечание. 143
6.4.3. ПРИМЕЧАНИЕ ЗАМЕЧАНИЯ 144
6.5 Сводка этой главы 145
Глава 7 Таблица API&SQL Введение и использование 146
7.1 Tableenviroment Concept 146
7.1.1 Строительство среды развития 147
7.1.2 Основная работа таблица. 147
7.1.3 Внешний разъем 155
7.1.4 Время концепция 162
7.1.5 Временные таблицы временная таблица 166
7.2 API Table Flink Table 167
7.2.1 Пример приложения API таблицы API 167
7.2.2 Запрос данных и фильтрация 168
7.2.3 168
7.2.4 Операция агрегации 173
7.2.5 Многочисленная корреляция 175
7.2.6 Эпизоды операция 177
7.2.7 Операция сортировки 178
7.2.8 Написание данных 179
7.3 Flink SQL 179
7.3.1 экземпляр Flink SQL 179
7.3.2 Выполнить SQL 180
7.3.3 Запрос данных и фильтрация 181
7.3.4 182
7.3.5 Агломерация данных 184
7.3.6 Многочисленная корреляция 186
7.3.7 Операция эпизодов 187
7.3.8 Вывод данных 189
7.4 Пользовательская функция 189
7.4.1 Функция Scalaar 189
7.4.2 ТАБЛИЦА ФУНКЦИЯ 191
7.4.3 Функция агрегации 192
7.5 Пользовательский источник данных 193
7.5.1 Определение таблицы 193
7.5.2 Определение таблицы 196
7.5.3 ТАБЛИЧНОЕ ОПРЕДЕЛЕНИЕ 199
7.6 Сводка этой главы 201
ГЛАВА 8 ВВЕДЕНИЕ СТАКОГО СТАКОГО ИСПОЛЬЗОВАНИЯ Компонентов 202
8.1 обработка комплекса Flink Complex 202
8.1.1 Основная концепция 203
8.1.2 Паттерн API 204
8.1.3 Приобретение инцидентов 210
8.1.4 Пример приложения 212
8.2 Применение расчета диаграммы Flink Gelly 213
8.2.1 Основная концепция 213
8.2.2 График API 214
8.2.3 Обработка итерационной диаграммы 220
8.2.4 Генератор рисунка 226
8.3 Приложение для машинного обучения Flinkml 227
8.3.1 Основная концепция 227
8.3.2 Существует руководитель обучения 229
8.3.3 Предварительная обработка данных 231
8.3.4 Рекомендуемый алгоритм 234
8.3.5 Piplines в Flinkml 235
8.4 Резюме этой главы 236
Глава 9 развертывание и приложение Flink 237
9.1 развертывание кластера Flink Cluster 237
9.1.1. 238
9.1.2 Развертывание кластера пряжи 240
9.1.3 развертывание кластера Kubernetes 244
9.2 Flink High доступная конфигурация 247
9.2.1 Стандартный кластер высокий доступный конфигурация 248
9.2.2 Кластер сеанса пряжи Высокая доступная конфигурация 250
9.3 управление безопасностью Flink 251
9.3.1 Цели сертификации 251
9.3.2 Конфигурация сертификации 252
9.3.3 Конфигурация SSL 253
9.4 Обновление кластера Flink 255
9.4.1 Задача задачи 256
9.4.2 Поддержание статуса 256
9.4.3 Обновление версии 257
9.5 Резюме этой главы 258
Глава 1 Мониторинг Flink и оптимизация производительности 259
10.1 Индикатор мониторинга"