Apache Flink は、Apache Software Foundation によって開発されたオープン ソースのストリーム処理フレームワークであり、そのコアは Java と Scala で書かれた 分散ストリーミング データ フロー エンジンです。 Flink は、任意のストリーミング データ プログラムをデータ並列およびパイプライン方式で実行します。Flink のパイプライン ランタイム システムは、バッチおよびストリーム処理プログラムを実行できます。さらに、Flink のランタイム自体も反復アルゴリズムの実行をサポートしています。
Flink は、高スループット、低遅延のストリーミング データ エンジンと、イベント時処理と状態管理のサポートを提供します。 Flink アプリケーションは、マシンに障害が発生した場合でも耐障害性があり、1 回限りのセマンティクスをサポートします。プログラムは Java、Scala [9]、Python [9]、SQL などの言語で記述でき、クラスターまたはクラウド環境で実行されるデータ フロー プログラムに自動的にコンパイルおよび最適化されます。
Flink は独自のデータ ストレージ システムを提供しませんが、Amazon Kinesis、Apache Kafka、HDFS、Apache Cassandra、ElasticSearch などのシステムにデータ ソースとシンクを提供します。
Apache Flink のデータ フロー プログラミング モデルは、有限および無限のデータ セットに対するイベントごとの処理を提供します。基本レベルでは、Flink プログラムはストリームと変換で構成されます。 「概念的には、ストリームはデータ ストリームの (おそらく終わりのない) 記録であり、変換は 1 つ以上のストリームを入力として受け取り、1 つ以上の出力ストリームを生成する操作です。」
Apache Flink には、2 つのコア API が含まれています。1 つは、制限付きまたは無制限のデータ ストリーム用の Data Stream API、もう 1 つは制限付きのデータ セット用の Data Set API です。 Flink は、Flink のデータ ストリームとデータセット API に簡単に埋め込むことができる、リレーショナル ストリーミングおよびバッチ処理用の SQL に似た式言語であるテーブル API も提供します。 Flink でサポートされる最高レベルの言語は SQL です。SQL は意味的にテーブル API に似ており、プログラムを SQL クエリ式として表します。
Apache 関連の知識の詳細については、Apache 使用法チュートリアル 列をご覧ください。
以上がApacheフリンクとは何ですかの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。