如何将字符串传递给sqoop中的按条件拆分
how to pass string into split by condition in sqoop
我有一个这样的 sqoop 查询。
sqoop import -Ddb2.jcc.sslConnection=true --connect jdbc:db2://192.1.1.2:6060/DB2M --username ${username} --password $password --query "
SELECT ACCOUNT_DATE,DIV_VALUE,from ${qualifier}.DTL where year = '${year}' AND SUBSTR(LOSS_TRAN,1,1) NOT IN ('1','9') and $CONDITIONS " -m 500 --split-by "DIV_VALUE" --fields-terminated-by '|' --target-dir s3://test${env}/${year}
拆分命令抛出异常。我无法通过 function.Any 帮助将字符串传递到 Split 中。
拆分，默认查找整数列。如果要使用字符串列进行拆分，需要启用属性：
-Dorg.apache.sqoop.splitter.allow_text_splitter=true 在您的 Sqoop 命令中。
我有一个这样的 sqoop 查询。
sqoop import -Ddb2.jcc.sslConnection=true --connect jdbc:db2://192.1.1.2:6060/DB2M --username ${username} --password $password --query "
SELECT ACCOUNT_DATE,DIV_VALUE,from ${qualifier}.DTL where year = '${year}' AND SUBSTR(LOSS_TRAN,1,1) NOT IN ('1','9') and $CONDITIONS " -m 500 --split-by "DIV_VALUE" --fields-terminated-by '|' --target-dir s3://test${env}/${year}
拆分命令抛出异常。我无法通过 function.Any 帮助将字符串传递到 Split 中。
拆分，默认查找整数列。如果要使用字符串列进行拆分，需要启用属性：
-Dorg.apache.sqoop.splitter.allow_text_splitter=true 在您的 Sqoop 命令中。