0

我正在构建一个管道，该管道使用数据库插件连接到本地 Oracle 数据库，查询两个表 ( table_a, table_b)，然后使用 Joiner 插件连接这些表，然后再上传到 BigQuery 表。

我现在遇到的问题是，当我在数据库插件中使用时，要加入table_a的外键table_b具有不同的数据类型。Get Schema在 Joiner 中，我正在加入table_a.customer_id = table_b.customer_id.

table_a.customer_idis LONGbut table_b.customer_idis的dtype DOUBLE。在源 Oracle DB 中，两列实际上都是整数。但是，出于某种原因， usingGet Schema认为它们是LONGand DOUBLE。

我显然在 Joiner 尝试加入具有不同数据类型的外键时遇到错误。

有没有办法转换/转换表中的列以匹配，以便我可以使用 Joiner？

我已经看到了一些使用 Wrangler Transform 解析日期的示例，但我没有看到任何可以转换为任何其他数据类型的内容。我也找不到任何指令示例：https ://github.com/data-integrations/wrangler 。

管道

4

1 回答 1

1

您可以使用 Cloud Data Fusion 提供的任何转换插件在加入数据之前转换数据。正如@muscat 提到的，您可以使用 Wrangler 转换并利用Set 类型指令，或者您可以使用 Projection 转换并配置 Convert 字段。

于 2020-03-03T22:53:47.013 回答