処理コンポーネントの定義 - Cloud - 8.0

addComponent {
	setComponentDefinition {
		TYPE: "tMap",
		NAME: "tMap_1",
		POSITION: 480, 256
	}
}

この例では、idカラムとageカラムのデータ型は入力スキーマでは文字列型ですが、出力スキーマでは整数型になっています。コンポーネントのデータ型自動変換機能を有効にして、その他の設定はデフォルトのままにします。

	setSettings {
		ENABLE_AUTO_CONVERT_TYPE : "true"
	}

この例では出力フローの名前がoutで、次の4つのカラムで構成されています。

• id、整数型、2桁

• full_name、文字列型

• age、整数型、2桁

• city、文字列型

	addSchema {
		NAME: "out",
		CONNECTOR: "FLOW",
		LABEL: "out"
		addColumn {
			NAME: "id",
			TYPE: "id_Integer",
			LENGTH: 2
		}
		addColumn {
			NAME: "full_name",
			TYPE: "id_String"
		}
		addColumn {
			NAME: "age",
			TYPE: "id_Integer",
			LENGTH: 2
		}
		addColumn {
			NAME: "city",
			TYPE: "id_String"
		}
	}

カラム定義は1番目のtFileInputDelimitedコンポーネントのカラム定義と同じであることが必要です。

	addMapperData {
		addInputTable {
			NAME: "row1"
			addColumn {
				NAME: "id",
				TYPE: "id_String"
			}
			addColumn {
				NAME: "name",
				TYPE: "id_String"
			}
			addColumn {
				NAME: "age",
				TYPE: "id_String"
			}
			addColumn {
				NAME: "city",
				TYPE: "id_String"
			}
		}
	}

カラム定義は2番目のtFileInputDelimitedコンポーネントのカラム定義と同じであることが必要です。

この例では、左外部結合を定義しています。内部結合を定義するには、ISINNERJOIN: trueパラメーターをaddInputTable {}関数に追加します。

		addInputTable {
			NAME: "row2"
			addColumn {
				NAME: "id",
				TYPE: "id_String"
				EXPRESSION: "row1.id"
			}
			addColumn {
				NAME: "family",
				TYPE: "id_String"
			}
		}

カラム定義はスキーマ設定で定義されているものと同じであることが必要です。IDパラメーターは必須ですが、IDが必要なのは、出力テーブルがリポジトリースキーマを使用する場合のみです。

full_nameカラムはメイン入力フローのnameカラムとルックアップフローのfamilyカラムの組み合わせとなり、この間にスペースを1つ入力します。

		addOutputTable {
			ID: "",
			NAME: "out"
			addColumn {
				NAME: "id",
				TYPE: "id_Integer",
				EXPRESSION: "row1.id"
			}
			addColumn {
				NAME: "full_name",
				TYPE: "id_String",
				EXPRESSION: "row1.name  + \" \" + row2.family"
			}
			addColumn {
				NAME: "age",
				TYPE: "id_Integer",
				EXPRESSION: "row1.age"
			}
			addColumn {
				NAME: "city",
				TYPE: "id_String",
				EXPRESSION: "row1.city "
			}
		}