tDSOutput / tDataStewardshipTaskOutput

プロパティタイプ

[Built-in] (組み込み)または[Repository] (リポジトリー)のいずれかで次の設定を行います。

[Built-in] (組み込み): そのコンポーネントに対してのみスキーマを作成し、ローカルに保管します。

[Repository] (リポジトリー): スキーマは作成済みで、リポジトリーに保管されています。さまざまなプロジェクトやジョブデザインで再利用できます。

[Schema] (スキーマ)と[Edit schema] (スキーマを編集)

スキーマとは行の説明のことです。処理して次のコンポーネントに渡すフィールド(カラム)数を定義します。Sparkジョブを作成する場合、フィールドの命名時は予約語のlineを避けます。

スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを利用できます。

• [View schema] (スキーマを表示): スキーマのみを表示する場合は、このオプションを選択します。

• [Change to built-in property] (組み込みのプロパティに変更): ローカルで変更を行うためにスキーマを組み込みに変更する場合は、このオプションを選択します。

• [Update repository connection] (リポジトリー接続をアップデート): リポジトリーに保存されているスキーマに変更を加え、変更後にそのコンテンツをすべてのジョブにプロパゲートするかどうかを決める場合は、このオプションを選択します。

  変更を現在のジョブにのみ反映する場合は、変更後、[No] (いいえ)を選択し、[Repository Content] (リポジトリーコンテンツ)ウィンドウで再びこのスキーマのメタデータを選択します。

[Sprint] (スプリント)リストからスプリントを選択すると、tDSOutputではキャンペーンで定義されているスキーマが認識され、基本設定で同一のスキーマカラムが作成されます。

[URL]

Qlik Cloudテナントのアドレス(例: https://qcs.us.qlikcloud.com/)を入力します。

スプリント

レベルが選択されない場合、デフォルトでは[Medium] (中)が使用されます。

[Assignee] (割り当て先)

タスクを作成するスプリント参加者を選択します。あるいは、[No assignee] (割り当て先なし) を選択して、タスクを誰にも割り当てずに作成します。

[Tags] (タグ) (オプション)

作成するタスクに関連付けるタグを入力します。

このタグを使用して、スプリントにロードするタスクをフィルタリングできます。

[tStatCatcher Statistics] (tStatCatcher統計)

このチェックボックスをオンにすると、ジョブレベルおよび各コンポーネントレベルでジョブ処理メタデータが収集されます。

[Maximum number of retries] (最大再試行回数)

タイムアウト例外を返し、ジョブを強制終了するまでのリクエスト再試行する回数を設定します。

[Batch Size] (バッチサイズ)

各処理バッチに含める行数を設定します。

パフォーマンスの問題が発生している場合を除き、デフォルト値は変更しないでください。バッチサイズを大きくするとパフォーマンスが向上しますが、高すぎる値を設定すると、ジョブの失敗の原因となる可能性があります。

プロパティタイプ

[Built-in] (組み込み)または[Repository] (リポジトリー)のいずれかで次の設定を行います。

[Built-in] (組み込み): そのコンポーネントに対してのみスキーマを作成し、ローカルに保管します。

[Repository] (リポジトリー): スキーマは作成済みで、リポジトリーに保管されています。さまざまなプロジェクトやジョブデザインで再利用できます。

[Schema] (スキーマ)と[Edit schema] (スキーマを編集)

スキーマとは行の説明のことです。処理して次のコンポーネントに渡すフィールド(カラム)数を定義します。Sparkジョブを作成する場合、フィールドの命名時は予約語のlineを避けます。

スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを利用できます。

• [View schema] (スキーマを表示): スキーマのみを表示する場合は、このオプションを選択します。

• [Change to built-in property] (組み込みのプロパティに変更): ローカルで変更を行うためにスキーマを組み込みに変更する場合は、このオプションを選択します。

• [Update repository connection] (リポジトリー接続をアップデート): リポジトリーに保存されているスキーマに変更を加え、変更後にそのコンテンツをすべてのジョブにプロパゲートするかどうかを決める場合は、このオプションを選択します。

  変更を現在のジョブにのみ反映する場合は、変更後、[No] (いいえ)を選択し、[Repository Content] (リポジトリーコンテンツ)ウィンドウで再びこのスキーマのメタデータを選択します。

[MERGING] (マージング)または[GROUPING] (グルーピング)キャンペーンでタスクを書き込むように選択した場合、以下のカラムが自動的にスキーマに追加されます:

URL

http://<server_address>:19999/data-stewardship/)のように、Talend Data Stewardshipサーバーにアクセスするアドレスに/data-stewardship/というサフィックスを付けて入力します。

[Username] (ユーザー名)と[Password] (パスワード)

Talend Data Stewardshipにログインするための認証情報を入力します。

パスワードを入力するためには、パスワードフィールドの横にある[...]ボタンをクリックし、ポップアップダイアログボックスにパスワードを二重引用符で囲んで入力して[OK]をクリックし、設定を保存します。

キャンペーン

[Find a campaign] (キャンペーンの検索)をクリックして、Talend Data Stewardshipで利用可能なすべてのキャンペーンのリストを開き、タスクが保存されているキャンペーンの名前を選択します。これは情報提示の読み取り専用フィールドです。

[Type] (タイプ)

キャンペーンの選択後に定義済みのタイプからキャンペーンタイプを表示する読み取り専用リスト。

[Override enforcement of data model] (データモデルの強制オーバーライド)

スキーマタイプが有効でない場合でもTalend Data Stewardshipサーバーでデータを処理する場合は、このチェックボックスを選択してください。この場合、スキーマの入力検証は行われません。

State

タスクを作成するワークフロー内の状態をリストから選択します。

このリストには、キャンペーンワークフロー内で定義するすべての状態の名前が表示されます。ここには、最初と最後の状態、およびTalend Data Stewardshipでキャンペーンを作成する時に追加する検証状態が表示されます。

さまざまな値に応じてさまざまな状態を定義できるよう値をコンテキスト化したい場合は、[Custom] (カスタム)オプションを使います。たとえば、すべての入力フィールドをチェックしたい場合は[State] (状態)フィールドに"New"という値を割り当てます。入力値が確信できるもので、ただ検証したい場合は、このフィールドに"To validate"という値を割り当てます。

[Assignee] (割り当て先)

タスクを作成するキャンペーン参加者を選択します。あるいは、[No Assignee] (割り当て先なし) を選択して、タスクを誰にも割り当てずに作成します。

[Custom] (カスタム)オプションを使用すると、表示されているフィールドにコンテキスト変数を定義することで、キャンペーンのデータスチュワードの部分にタスクを動的に割り当てることができます。想定される値はスチュワードのログイン情報となります。

このオプションを使用し、受信データの指定された属性に基づいて特定のスチュワードにタスクを割り当てることができます。たとえば、フランスの顧客にはフランス人スチュワードJacques Bocuse、米国の顧客にはアメリカ人スチュワードCale Carolinaを割り当てるようにする、顧客サポートレベルがプラチナの場合はサポートチームリードに割り当て、ゴールドの場合はエキスパートに割り当てる、などのようにできます。

[Priority] (優先度)、[Choice] (選択)および[Tags] (タグ)

[Priority] (優先度)(任意): タスク優先度のいずれかを選択します。あるいは、[Custom] (カスタム)を選択し、表示されるフィールドにカスタムの式を設定するために使われます。

レベルが選択されない場合、デフォルトでは[Medium] (中)が使用されます。

[Choice] (選択) (任意、[ARBITRATION] (アービトレーション)キャンペーンが選択を選択している場合のみ使用可能): Webアプリケーションでキャンペーンを定義する際、キャンペーンのレコードに設定する任意の選択オプションを選びます。デフォルト値は[No Choice] (選択なし)で、この選択によりデータスチュワードはWebアプリケーションで作業を行うことができます。ただし、ジョブでアービトレーションの選択を設定することで、タスク作成時に最も関連性が高いと思われる選択項目を事前に選択することによりスチュワードをサポートできます。

[Tags] (タグ) (任意): 作成するタスクに関連付けるタグを入力します。

このタグを使用して、キャンペーンにロードするタスクをフィルタリングできます。

[Comments] (コメント) (オプション)

1つまたは複数のスキーマカラムを選択し、作成するタスクに追加のコメントを入力します。

このテーブルではデフォルトですべてのスキーマカラムがリスト表示されます。

キャンペーン参加者は、Talend Data Stewardshipのソースレコードカラムにポインターを置くことで、いつでもコメントを表示できます。この情報はタスクを解決する際に、より多くの情報を得た上で判断するのに役立ちます。

[Campaign ID] (キャンペーンID)

基本設定でキャンペーンを選択すると、そのキャンペーンの技術的な名前を表示します。ただし、フィールド値を変更して、たとえばコンテキストパラメーターに置き換え、ランタイムにコンテキスト変数をジョブにパスできます。この技術的な名前は、ジョブがTalend Data Stewardshipと通信する時に、[Campaign] (キャンペーン)フィールドの値に関係なく、キャンペーンの特定に常に使用されます。

[Max tasks per commit] (コミットあたりの最大タスク数)

各回のコミットのタスク数を設定します。

Talend Data Stewardshipのバッチサイズに制限はありません(オンプレミス)。

ただし、Talend Cloud Data Stewardshipでは、1回のコミットで200件のタスクを超えないようにする必要があり、大きな値を設定するとジョブで障害が発生します。

[Connect Timeout] (接続タイムアウト): 接続の試行に失敗してジョブが強制終了するまでの時間(ミリ秒)を設定するために使われます。

[Request Timeout] (リクエストタイムアウト): リクエストの試行に失敗してジョブが強制終了するまでの時間(ミリ秒)を設定するために使われます。

値を0にすると待ち時間が無限であると解釈されます。

[tStatCatcher Statistics] (tStatCatcher統計)

このチェックボックスをオンにすると、ジョブレベルおよび各コンポーネントレベルでジョブ処理メタデータが収集されます。

NB_LINE

処理されたメッセージの数。これはAfter変数で、整数を返します。

NB_REJECT

リジェクトされた行数。これはAfter変数で、整数を返します。

NB_SUCCESS

正しく処理された行数。これはAfter変数で、整数を返します。

ERROR_MESSAGE

エラー発生時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。この変数はコンポーネントにこのチェックボックスが存在し、[Die on error] (エラー発生時に強制終了)がオフになっている場合のみファンクションします。

使用ルール

このコンポーネントは通常、ジョブまたはサブジョブの終了コンポーネントとして使い、常に入力リンクが必要です。