これらのプロパティは、Spark Streamingジョブのフレームワークで実行されるtDataDecryptを設定するために使われます。
標準のtDataDecryptコンポーネントは、データクオリティファミリーに属しています。
このフレームワーク内のコンポーネントは、Talend Data Management Platform、Talend Big Data Platform、Talend Real-Time Big Data Platform、Talend Data Services Platform、およびTalend Data Fabricで使用できます。
基本設定
|
[Schema] (スキーマ)と[Edit schema] (スキーマを編集) |
スキーマとは行の説明のことです。処理して次のコンポーネントに渡すフィールド(カラム)数を定義します。Sparkジョブを作成する場合、フィールドの命名時は予約語のlineを避けます。 ジョブで接続している先行コンポーネントからスキーマを取得するためには、[Sync columns] (カラムを同期)をクリックします。 スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを利用できます。
|
| [Secret method] (シークレット方式) |
入力データの暗号化に使うシークレット方式として次のいずれかを選択します。
|
|
Password |
シークレット方式として暗号化ファイルを選択した場合に利用できます。 tDataEncryptコンポーネントによって生成された暗号化ファイルの暗号化に使用されるパスワードを入力します。 この値は二重引用符で囲む必要があります。 |
|
[Cryptographic file path] (暗号化ファイルのパス) |
シークレット方式として暗号化ファイルを選択した場合に利用できます。 tDataEncryptのコンポーネントを使用して入力データを暗号化するために使用される暗号化ファイルへのパスを入力します。 この値は二重引用符で囲む必要があります。 |
| [Cryptographic method] (暗号方式) |
シークレット方式として256ビットキー(base64でエンコード)を選択した場合に利用できます。 入力データの暗号化に使うシークレット方式として次のいずれかを選択します。
|
| [Secret key] (シークレットキー) |
シークレット方式として256ビットキー(base64でエンコード)を選択した場合に利用できます。 この値は二重引用符で囲む必要があります。 入力データの暗号化に使うキーを入力します。 |
|
解読するカラム |
対応する [Decrypt] (復号化)チェックボックスをオンにして、入力カラムを復号化します。 選択されていないカラムは復号化されません。コンポーネントの出力スキーマを適切に設定して、復号化するカラムのタイプを文字列に設定します。 次のデータは復号化できません。
|
| [Die on error] (エラー発生時に強制終了) |
このチェックボックスをオンにすると、エラー発生時にジョブの実行が停止されます。
重要: このチェックボックスをオフにすると、無効な入力データは復号化されず、出力データとして保持されます。
|
詳細設定
| キー導出関数 | データを暗号化する場合と同じキー導出関数を選択します。デフォルトでは[PBKDF2 with 300,000 iterations] (反復回数が30万回のPBKDF2)が選択されています。 |
|
[tStatCatcher Statistics] (tStatCatcher統計) |
このチェックボックスをオンにすると、ジョブレベルおよび各コンポーネントレベルでジョブ処理メタデータが収集されます。 |
使用方法
|
使用ルール |
このコンポーネントは通常、中間コンポーネントとして使用されます。入力コンポーネントと出力コンポーネントが必要です。 |
|
[Spark Connection] (Spark接続) |
[Run] (実行)ビューの[Spark configuration] (Spark設定)タブで、ジョブ全体でのSparkクラスターへの接続を定義します。また、ジョブでは、依存jarファイルを実行することを想定しているため、Sparkがこれらのjarファイルにアクセスできるように、これらのファイルの転送先にするファイルシステム内のディレクトリーを指定する必要があります。
この接続は、ジョブごとに有効になります。 |