Apache Flink: различия между версиями
[отпатрулированная версия] | [отпатрулированная версия] |
Содержимое удалено Содержимое добавлено
Neon (обсуждение | вклад) Нет описания правки |
Neon (обсуждение | вклад) |
||
Строка 30:
=== DataStream API ===
DataStream API в системе Flink проводит преобразования - такие как фильтрацию, агрегацию, выборку - на ограниченных или неограниченных потоках данных. DataStream API включает в себя более 20 различных типов преобразования, которые могут быть использованы на языках Java
Вот пример простой обработки потока для счётчика количества слов в непрерывном входном потоке по пятисекундным временным интервалам:
|