Ядром Flink является механизм потоковой передачи данных, который обеспечивает распределение данных, связь и отказоустойчивость для распределенных вычислений по потокам данных.
Flink включает в себя несколько API для создания приложений, использующих движок Flink:
DataSet API для статических данных, встроенных в Java, Scala и Python,
DataStream API для неограниченных потоков, встроенных в Java и Scala, и
Table API с SQL-подобным языком выражений, встроенным в Java и Scala.
Flink также объединяет библиотеки для конкретных случаев использования:
Библиотека машинного обучения и
Gelly — API и библиотека для обработки графов.
Вы можете легко интегрировать Flink с другими известными системами с открытым исходным кодом как для ввода и вывода данных, так и для развертывания.
(ранее Стратосфера)