ジョブを変換 - 7.2

Talend Big Data Platform入門ガイド

EnrichVersion
7.2
EnrichProdName
Talend Big Data Platform
EnrichPlatform
Talend Administration Center
Talend DQ Portal
Talend Installer
Talend Runtime
Talend Studio
task
インストールとアップグレード
ジョブデザインと開発
データクオリティとプレパレーション > データクレンジング
データクオリティとプレパレーション > データプロファイリング
既存のSparkバッチジョブからSparkストリーミングジョブへの変換

始める前に

手順

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

    [Duplicate] (複製)ウィンドウが開きます。

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

    aggregate_movie_director_spark_streamingジョブが[Repository] (リポジトリー)[Big Data Streaming] (ビッグデータストリーミング)ノードに表示されます。

  6. ノードを右クリックし、コンテキストメニューから[Create folder] (フォルダーの作成)を選択します。
  7. [New Folder] (新規フォルダー) ウィザードで新しいフォルダーにstreaming_moviesという名前を付け、[Finish] (終了)をクリックしてフォルダーを作成します。
  8. aggregate_movie_director_spark_streamingジョブをこのstreaming_moviesフォルダーにドロップします。

タスクの結果

この新しいSparkストリーミングジョブは、さらに編集できる状態になっています。