コンポーネントのスタック

ソフトウェア スタックとして、Flinkは多層のシステムです。スタックの異なる層がお互いの上に構築され、それらが受け付けたプログラムの表現の抽象レベルを上げます。

  • ランタイム層は JobGraphの形でプログラムを受け取ります。ジョブグラフはデータストリームを消費および生成する任意のタスクを持つ一般的な並行データフローです。

  • DataStream API および DataSet API の両方は、個々の編集処理を通してジョブグラフを生成します。データセットAPIはプログラムのための最適化プランを決定するためにオプティマイザを使用しますが、データストリーム APIはストリームビルダーを使用します。

  • ジョブグラフはFlinkで利用可能な様々な配備オプションに応じて実行されます(例えば、ローカル、リモート、YARNなど)。

  • Flinkと同梱されているライブラリとAPIはデータセットあるいはデータストリームAPIプログラムを生成します。これらは論理的なテーブル、機械学習のためのFlinkML、およびグラフ処理のためのGellyへのクエリのためのテーブルです。

更に詳しく学ぶために図の中のコンポーネントをクリックすることができます。

Apache Flink: スタック

上に戻る

TOP
inserted by FC2 system