コンポーネントをリンクする - 7.0

データレコードをフィルター処理するジョブスクリプトを作成する

author
Talend Documentation Team
EnrichVersion
7.0
EnrichProdName
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Real-Time Big Data Platform
task
ジョブデザインと開発 > サードパーティーシステム > カスタムコードコンポーネント > Javaカスタムコードコンポーネント
ジョブデザインと開発 > サードパーティーシステム > ファイルコンポーネント > 列区切り文字付き
ジョブデザインと開発 > サードパーティーシステム > プロセス制御コンポーネント
ジョブデザインと開発 > サードパーティーシステム > ロギングコンポーネント
ジョブデザインと開発 > サードパーティーシステム > 変換処理コンポーネント
データガバナンス > サードパーティーシステム > カスタムコードコンポーネント > Javaカスタムコードコンポーネント
データガバナンス > サードパーティーシステム > ファイルコンポーネント > 列区切り文字付き
データガバナンス > サードパーティーシステム > プロセス制御コンポーネント
データガバナンス > サードパーティーシステム > ロギングコンポーネント
データガバナンス > サードパーティーシステム > 変換処理コンポーネント
データクオリティとプレパレーション > サードパーティーシステム > カスタムコードコンポーネント > Javaカスタムコードコンポーネント
データクオリティとプレパレーション > サードパーティーシステム > ファイルコンポーネント > 列区切り文字付き
データクオリティとプレパレーション > サードパーティーシステム > プロセス制御コンポーネント
データクオリティとプレパレーション > サードパーティーシステム > ロギングコンポーネント
データクオリティとプレパレーション > サードパーティーシステム > 変換処理コンポーネント
EnrichPlatform
Talend CommandLine
Talend Studio

ジョブ内のコンポーネントとサブジョブをリンクする接続を追加および定義するには、以下の手順に従います。

手順

  1. 次のスクリプトノードを入力し、tFileInputDelimitedコンポーネントとtReplicateコンポーネント間にメイン行接続を定義します。
    // add connections
    addConnection {
    	TYPE: "FLOW",
    	NAME: "row1",
    	LINESTYLE: 0,
    	SOURCE: "tFileInputDelimited_1",
    	TARGET: "tReplicate_1"
    }
  2. 次のスクリプトノードを入力し、tReplicateコンポーネントとtLogRowコンポーネント間にメイン行接続を定義します。
    addConnection {
    	TYPE: "FLOW",
    	NAME: "row2",
    	LINESTYLE: 0,
    	SOURCE: "tReplicate_1",
    	TARGET: "tLogRow_1"
    }
  3. 次のスクリプトノードを入力し、tReplicateコンポーネントとtFilterColumnsコンポーネント間にメイン行接続を定義します。
    addConnection {
    	TYPE: "FLOW",
    	NAME: "row3",
    	LINESTYLE: 0,
    	SOURCE: "tReplicate_1",
    	TARGET: "tFilterColumns_1"
    }
  4. 次のスクリプトノードを入力し、tFilterColumnsコンポーネントとtFilterRowコンポーネント間にメイン行接続を定義します。
    addConnection {
    	TYPE: "FLOW",
    	NAME: "row4",
    	LINESTYLE: 0,
    	SOURCE: "tFilterColumns_1",
    	TARGET: "tFilterRow_1"
    }
  5. 次のスクリプトノードを入力し、tFilterRowコンポーネントとtLogRowコンポーネント間にフィルター行接続を定義します。
    addConnection {
    	TYPE: "FILTER",
    	NAME: "row5",
    	LINESTYLE: 0,
    	SOURCE: "tFilterRow_1",
    	TARGET: "tLogRow_2"
    }
  6. 次のスクリプトノードを入力し、tFilterRowコンポーネントとtLogRowコンポーネント間にリジェクト行接続を定義します。
    addConnection {
    	TYPE: "REJECT",
    	NAME: "row6",
    	LINESTYLE: 0,
    	SOURCE: "tFilterRow_1",
    	TARGET: "tLogRow_3"
    }
  7. 次のスクリプトコードを入力して、tFileInputDelimitedコンポーネントとtJavaコンポーネント間にOnSubjobOkトリガー接続を定義して、最初のサブジョブが成功すると2つ目のサブジョブがトリガーされるように、2つのサブジョブをリンクします。
    addConnection {
    	TYPE: "SUBJOB_OK",
    	NAME: "OnSubjobOk",
    	LINESTYLE: 1,
    	SOURCE: "tFileInputDelimited_1",
    	TARGET: "tJava_1"
    }