tDataStewardshipTaskInputの標準プロパティ

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

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

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

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

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

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

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

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

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

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

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

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

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

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

有効ではないスキーマタイプでもあえてTalend Data Stewardshipサーバーのデータを処理する場合は、このチェックボックスを選択し、スキーマの入力検証を実行しないようにします。

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

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

[Any State] (任意の状態)オプションを使うと、状態に関係なくすべてのタスクが取得されます。

[Custom] (カスタム)オプションを使うと、取得するタスクのさまざまな状態をコンマで区切って指定できます(例: "New,toValidate1,Resolved")。ワークフローで定義する状態の正確なラベルを入力する必要があります。

取得するタスクを持つキャンペーン参加者を選択します。

[No Assignee] (割り当て先なし)は、どのデータスチュワードにも割り当てられていないタスクを取得します。他方、[Any Assignee] (任意の割り当て先)は、どの割り当て先も考慮せずにタスクを取得します。

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

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

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

レベルが選択されていない場合は、[Any Priority] (任意の優先度)によって優先度に関わらずすべてのタスクが取得されます。

Choice (選択)(オプションでアービトレーションキャンペーンが選択されている場合のみ使用可能): キャンペーンのレコードに設定されている任意の選択オプションを選びます。

[No Choice] (選択なし)では、データスチュワードによって選択肢が選ばれていないタスクが取得されます。他方、[Any Choice] (任意の選択)では、選ばれた選択肢に関係なくすべてのタスクが取得されます。

Tags (タグ) (オプション): 取得したいタスクに関連付けるタグを入力します。タグはタスクのフィルタリングに使用できます。

キャンペーンから取得するタスクのフィルタリングに使用するクエリーステートメントを入力します。

条件はフィールド名、演算子、および値で構成されます。レコードのデータを参照する場合は、フィールド名の先頭にrecord.が付いていなければなりません。文字列の前後に一重引用符を使用し、文字列内の引用符の前にバックスラッシュを付ける必要があります。例: レコードにFirstNameフィールドがある場合、タスクを割り当て先と名前の値でフィルタリングするには、[Assignee] (割り当て先)フィールドでassignee='user1@talend.com'を使い、[Query] (クエリー)フィールドにrecord.firstName='De\'wayne'と入力します。

詳細は、Data StewardshipコンポーネントとREST APIで使われるクエリー言語をご覧ください。

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

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

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

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

このオプションは、タスクの最後のタスクIDに依存して次のタスクを取得することでタスク取得時のパフォーマンスを向上させます。

各処理バッチに含める行数を設定するために使われます。

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

このチェックボックスはデフォルトでオンになっており、タスクがコンポーネントによって取得されると、 Talend Data Stewardship サーバーで使用済みとしてマークされます。同じフィルター条件でジョブを再実行した場合、2回目にはタスクは取得されません。

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

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

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

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