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