第4章 Apache Flinkの開発環境のセットアップ Apache Flinkの開発環境をセットアップする
この作品はAIを使って翻訳されている。ご意見、ご感想をお待ちしている:translation-feedback@oreilly.com
さて、 全ての知識を得たので、いよいよ手を動かして Flink アプリケーションの開発を始めよう!この章では、Flink アプリケーションを開発、実行、デバッグするための環境のセットアップ方法を学ぶ。この章では、Flink アプリケーションを開発し、実行し、デバッグするための環境をどのようにセットアップするかについて学ぶ。これらのサンプルを使って、Flink アプリケーションが IDE でどのように実行され、デバッグされるかを示す。最後に、新しいアプリケーションの出発点であるFlink MavenプロジェクトをBootstrapする方法を示す。
必要なソフトウェア
まず、Flink アプリケーションの開発に必要なソフトウェア について説明しよう。Linux、macOS、Windows上でFlinkアプリケーションを開発・実行できる。しかし、UNIX ベースのセットアップが最も豊富なツール・サポートを享受できるのは、ほとんどの Flink 開発者がこの環境を好んでいるからだ。本章では UNIX ベースのセットアップを想定する。Windowsユーザであれば、Windows subsystem for Linux (WSL)、Cygwin、またはLinux仮想マシンを使って、UNIX環境でFlinkを実行することができる。
FlinkのDataStream APIはJavaとScalaで利用できる。したがって、FlinkのDataStreamアプリケーションを実装するにはJava JDKが必要である-Java JDK 8(またはそれ以上)。Java JREだけでは不十分である。
Flinkアプリケーションの開発には厳密には必要ないが、以下のソフトウェアもインストールされているものとする:
-
Apache Maven 3.x。この本のコード例では、Mavenのビルド管理を使用している。さらに、Flinkは新しいFlink MavenプロジェクトをブートストラップするためのMavenアーキタイプを提供している。
-
Javaおよび/またはScala開発用のIDE。一般的な選択肢としては、IntelliJ IDEA、Eclipse、Netbeansと、適切なプラグイン(Maven、Git、Scalaサポートなど)がある。IntelliJ IDEAの使用を推奨する。IntelliJ IDEAのWebサイトの 指示に従ってダウンロードし、インストールすることができる。
IDEでFlinkアプリケーションを実行してデバッグする
Flinkは分散データ処理システムだが、通常はローカルマシンで開発し、初期テストを実行する。これは開発を容易にし、クラスタデプロイを簡素化する。なぜなら、クラスタ環境で変更を加えることなく、まったく同じコードを実行できるからだ。以下では、ここで使用するコード例の入手方法、IntelliJへのインポート方法、サンプル・アプリケーションの実行方法、デバッグ方法について説明する。
IDEでこの本の例をインポートする
本書の コード例はGitHubでホストされている。本書のGitHubページには、ScalaのサンプルとJavaのサンプルのリポジトリが1つずつ発見できる。セットアップにはScalaのリポジトリを使うが、Javaが好きなら同じ指示に従うことができるはずだ。 ...
Become an O’Reilly member and get unlimited access to this title plus top books and audiobooks from O’Reilly and nearly 200 top publishers, thousands of courses curated by job role, 150+ live events each month,
and much more.
Read now
Unlock full access