Apache Flinkは、無限(連続して流れ込む)データストリームと有限のデータの両方に対して、状態を保持しながら計算を行うオープンソースの分散処理エンジンです。公式サイトでは、障害時も「exactly-once」の状態一貫性を保証し、YARNやKubernetes、スタンドアロンクラスタで動作すると説明されています。機能としてイベント時間処理、SQL・DataStream API・ProcessFunctionの各APIを備えています(2026年10月時点)。
Apache Flinkの定義と主要機能
ストリームとバッチの両方を状態付き計算として扱う点が公式の定義上の特徴です。