loop/iterate 中的 tHiveInput？
tHiveInput in a loop/iterate?
我目前有一个文件，每行都有一个 sql 查询。
我想用 tHDFSInput 读取这个文件的每一行，并用 tHiveInput 执行查询。
我怎样才能做到这一点 ？
我有这样的事情：
但它只进入 thiveinput 一次。
您应该考虑在 tHDFSInput 和 tHiveInput 的子作业之间使用组件 tFlowToIterate。
在下面的例子中，我生成了一个包含数字序列的流，然后针对每个数字，我在我的数据库上做了一个请求（我承认它不是 tHiveInput，但我想这是相同的逻辑）。
这是我在 tDBRow_1:
中使用的请求的配置
希望对您有所帮助。
我目前有一个文件，每行都有一个 sql 查询。
我想用 tHDFSInput 读取这个文件的每一行，并用 tHiveInput 执行查询。
我怎样才能做到这一点 ？
我有这样的事情：
您应该考虑在 tHDFSInput 和 tHiveInput 的子作业之间使用组件 tFlowToIterate。
在下面的例子中，我生成了一个包含数字序列的流，然后针对每个数字，我在我的数据库上做了一个请求（我承认它不是 tHiveInput，但我想这是相同的逻辑）。
这是我在 tDBRow_1:
希望对您有所帮助。