Flink на Scala (Java API)
О курсе
Подробнее
В этот раз мы займемся разработкой потоковых приложений Flink на Scala, но с использованием Java API. И изучим основные принципы работы со временем и состоянием при обработке непрерывно поступающих данных.
Пройдя этот курс и выполнив представленные в курсе практические задания, вы
поймете, как работает Flink
увидите, чем потоковая обработка отличается от пакетной
научитесь обрабатывать потоки непрерывно поступающих данных
развернете свой собственный кластер Flink и освоите запуск приложений на кластере
Модули курса:
DataStreams - это самый легкий модуль из всех, его прохождение занимает минимальное количество времени; после завершения данного модуля у вас будет четкое представление о базовой структуре приложений на Flink
Работа со временем - как следует из названия, в этом модуле работа пойдет со временем: мы разберем разницу между временем обработки и временем наступления события
Работа с состоянием - задача усложняется, теперь при разработке приложений мы будем учитывать не только время наступления событий, но и информацию о ранее обработанных событиях
Дополнительные возможности - здесь мы разберем боковой вывод, напишем собственные триггеры
Кластер Flink - наконец приступим к развертыванию кластера, подробно разберем архитектуру Flink
Практика - при решении задач в этом модуле вы примените все полученные на курсе знания, кроме того - научитесь визуализировать обработанные данные в kibana
- Разрабатывать будем приложения Flink на Scala, так что от вас ожидается знание основ Scala. Если вы проходили курс Основы Scala, то все необходимые знания у вас есть.
- Также для выполнения практических заданий следует установить на компьютер Docker (потребуется для прохождения четвертого модуля Кластер Flink) и IntelliJ IDEA.
Содержание
Программа курса
7 занятий№ТемаЧто внутри
01Введение- Приветствие
- Подготовка к работе
- Потоковая обработка данных
02DataStreams- Структура приложения
- Типы
- Преобразования
- Практика
03Работа со временем- Показатели времени
- Оконные операторы
- Объединение потоков
- Практика
04Работа с состоянием- Состояние
- Работа приложения
- Практика
05Дополнительные возможности- Триггеры
- Боковой вывод
- Практика
06Кластер Flink- Архитектура Flink
- Кластер
07Практика- Часть 1
- Часть 2
01Введение
- Приветствие
- Подготовка к работе
- Потоковая обработка данных
02DataStreams
- Структура приложения
- Типы
- Преобразования
- Практика
03Работа со временем
- Показатели времени
- Оконные операторы
- Объединение потоков
- Практика
04Работа с состоянием
- Состояние
- Работа приложения
- Практика
05Дополнительные возможности
- Триггеры
- Боковой вывод
- Практика
06Кластер Flink
- Архитектура Flink
- Кластер
07Практика
- Часть 1
- Часть 2
Организатор
Автор курса
StepikStepik — образовательная платформа и конструктор онлайн-курсов. Мы разрабатываем алгоритмы адаптивного обучения, сотрудничаем с авторами MOOC, помогаем в проведении олимпиад и программ переподготовки. Наша цель — сделать образование открытым и удобным.
Stepik — широко известная российская образовательная платформа, основанная в 2013 году. На Stepik зарегистрировано более миллиона пользователей из России и стран СНГ.
В настоящее время на Stepik представлены несколько тысяч учебных курсов на самые разные темы.
Подробнее об авторе Мнения учеников
Отзывы о курсе
Информация обновлена 3 сентября 2026 г.