ジョブを変換

既存のSpark BatchジョブからSpark Streamingジョブへの変換

始める前に

Talend Studioを起動し、Integrationパースペクティブを開いていること。
Apache Spark Batchジョブを使って映画とディレクターの情報を結合の説明に従い、aggregate_movie_director_sparkというSpark Batchジョブが作成されて正しく実行されていること。

手順

[Repository] (リポジトリー)ツリービューで、[Job Designs] (ジョブデザイン)ノード、[Big Data Batch] (ビッグデータバッチ)ノード、続いてgetting_startedフォルダーおよびsparkフォルダーを展開します。
aggregate_movie_director_sparkジョブを右クリックし、コンテキストメニューから[Duplicate] (複製)を選択します。

[Duplicate] (複製)ウィンドウが開きます。
[Input new name] (新しい名前の入力)フィールドで、複製にaggregate_movie_director_spark_streamingという名前を付けます。
[Job Type] (ジョブタイプ)ドロップダウンリストから、[Big Data Streaming] (ビッグデータストリーミング)を選択します。
[Framework] (フレームワーク)リストから[Spark Streaming] (Spark Streaming)を選択し、[OK]をクリックして変更を確定します。

aggregate_movie_director_spark_streamingジョブが[Repository] (リポジトリー)の[Big Data Streaming] (ビッグデータストリーミング)ノードに表示されます。
ノードを右クリックし、コンテキストメニューから[Create folder] (フォルダーの作成)を選択します。
[New Folder] (新規フォルダー) ウィザードで新しいフォルダーにstreaming_moviesという名前を付け、[Finish] (終了)をクリックしてフォルダーを作成します。
aggregate_movie_director_spark_streamingジョブをこのstreaming_moviesフォルダーにドロップします。

タスクの結果

この新しいSpark Streamingジョブは、さらに編集できる状態になっています。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。

こちらにフィードバックをお寄せください