# Apache Spark BatchのtLoopプロパティ

これらのプロパティは、Spark Batchジョブのフレームワークで実行されているtLoopを設定するために使われます。

Spark BatchのtLoopコンポーネントは、オーケストレーション化ファミリーに属しています。

このフレームワーク内のコンポーネントは、ビッグデータ対応のTalend 製品すべて、およびTalend Data Fabricで使用できます。

## 基本設定

| ループタイプ | 実行するループのタイプを選択します:ForまたはWhileのいずれか。<br><br>For: タスクは定義された反復回数だけ実行されます。<br><br>While: タスクまたはジョブは、条件が満たされるまで実行されます。 |
| --- | --- |
| For | <ul> <li> <p> <span>From</span>: ループを開始する最初のインスタンス番号を入力します。ステップ2で開始インスタンス数2の場合、インスタンス数が偶数の時にループが開始します。</p> </li> <li> <p> <span>To</span>: ループが終了する最後のインスタンス番号を入力します。</p> </li> <li> <p> <span>[Step] (ステップ)</span>: ループを増分するステップを入力します。ステップ2は、2番目のインスタンスごとに、という意味です。</p> </li> <li> <p> <span>[Values are increasing] (値は増加し続ける)</span>: このチェックボックスを選択すると、増加シーケンスのみが許可されます。このチェックボックスをオフにすると、減少シーケンスのみが許可されます。</p> </li> </ul> |
| While | <ul> <li> <p> <span>[Declaration] (宣言)</span>: ループを開始する式を入力します。</p> </li> <li> <p> <span>[Condition] (条件)</span>: ループが終了するために満たす必要がある条件を入力します。</p> </li> <li> <p> <span>[Iteration] (反復)</span>: 各ループで実行される操作を示す式を入力します。</p> </li> </ul> |

## グローバル変数

| グローバル変数 | ERROR\_MESSAGE: エラーが発生した時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。この変数はコンポーネントにこのチェックボックスが存在し、[Die on error] (エラー発生時に強制終了)がオフになっている場合のみ機能します。<br><br>CURRENT\_VALUE: 現在の値。Forタイプのループのみで利用できます。これはFlow変数で、整数を返します。<br><br>CURRENT\_ITERATION: 現在の繰り返し処理のシーケンス番号。これはFlow変数で、整数を返します。<br><br>Flow変数はのコンポーネントの実行中に機能し、After変数はコンポーネントの実行後に機能します。<br><br>フィールドまたは式に変数を入れるには、Ctrl + スペースを押して変数リストにアクセスし、リストから使用する変数を選択します。<br><br>変数の詳細は、*Talend Studio* *ユーザーガイド*をご覧ください。 |
| --- | --- |

## 使用方法

| **使用ルール** | tLoopは、開始コンポーネントとして使用されるコンポーネントで、次のコンポーネントと反復接続になっている場合のみ使用できます。 |
| --- | --- |
| For | From (差出人) |
|  | [To] (宛先) |
|  | 手順 |
|  | [Values are increasing] (値は増加し続ける) |
| While | [Declaration] (宣言) |
|  | 条件 |
|  | [Iteration] (反復) |
| [Spark Connection] (Spark接続) | [Run] (実行)ビューの[Spark configuration] (Spark設定)タブで、ジョブ全体でのSparkクラスターへの接続を定義します。また、ジョブでは、依存jarファイルを実行することを想定しているため、Sparkがこれらのjarファイルにアクセスできるように、これらのファイルの転送先にするファイルシステム内のディレクトリーを指定する必要があります。<br><br><ul> <li> <div> <span>Yarnモード</span>(YarnクライアントまたはYarnクラスター):<ul> <li> <p>Google Dataprocを使用している場合、<span>[Spark configuration] (Spark設定)</span>タブの<span>[Google Storage staging bucket] (Google Storageステージングバケット)</span>フィールドにバケットを指定します。</p> </li> <li> <p>HDInsightを使用している場合、<span>[Spark configuration] (Spark設定)</span>タブの<span>[Windows Azure Storage configuration] (Windows Azure Storage設定)</span>エリアでジョブのデプロイメントに使用するブロブを指定します。</p> </li> <li>Altusを使用する場合は、<span>[Spark configuration] (Spark設定)</span>タブでジョブのデプロイにS3バケットまたはAzure Data Lake Storageを指定します。</li> <li>Quboleを使用する場合は、ジョブに<span>tS3Configuration</span>を追加し、QuboleでS3システム内に実際のビジネスデータを書き込みます。<span>tS3Configuration</span>を使用しないと、このビジネスデータはQubole HDFSシステムに書き込まれ、クラスターをシャットダウンすると破棄されます。</li> <li> <p>オンプレミスのディストリビューションを使用する場合は、クラスターで使われているファイルシステムに対応する設定コンポーネントを使用します。一般的に、このシステムはHDFSになるため、<a href="https://help.qlik.com/talend/r/ja-JP/7.3/components/hdfs/thdfsconfiguration">tHDFSConfiguration</a>を使用します。</p> </li> </ul> </div> </li> <li> <p> <span>[Standalone mode] (スタンドアロンモード)</span>: クラスターで使われているファイルシステム(<a href="https://help.qlik.com/talend/r/ja-JP/7.3/components/hdfs/thdfsconfiguration-properties-for-apache-spark-batch">tHDFSConfiguration Apache Spark Batch</a>や<a href="https://help.qlik.com/talend/r/ja-JP/7.3/components/amazon-s3/ts3configuration-properties-for-apache-spark-batch">tS3Configuration Apache Spark Batch</a>など)に対応する設定コンポーネントを使用します。</p> <p>ジョブ内に設定コンポーネントがない状態でDatabricksを使用している場合、ビジネスデータはDBFS (Databricks Filesystem)に直接書き込まれます。</p> </li> </ul><br><br>この接続は、ジョブごとに有効になります。 |