parameter-passing - Datastage 增量计费
问题描述
我们想在 DataStage 中执行增量加载(在并行环境中)。只加载前一次加载和新加载之间的增量(用于创建、更新、删除 DWH 中的记录)。
我们希望存储上次加载期间恢复的最后一个密钥,以便能够在新加载时从下一条记录重新启动请求。
我们已经成功地使用了一个参数来过滤运行时的 SQL 负载查询。不幸的是,我们还没有找到检索最后一个键(max (Key) - Aggregator?)并将其存储在此参数中的可能性。
使用哪个阶段,在同一个并行作业中输出单个值,然后存储到参数?
有任何想法吗 ?
谢谢你的帮助。
解决方案
考虑从您的目标中获取最大值 - 它很可能是一个数据库,并且 max() 很容易做到。
查看我关于从“流”获取一些数据到参数的帖子
推荐阅读
- excel - 在 Mac VBA 中使用 curl 通过 HTTP POST 发送文件
- python - 使用元组过滤数组时出现意外行为
- oracle - MyBatis XML Mapper 文件中的 Oracle 错误,但在 SQL Developer 中没有
- python - 根据列表中的存在创建新的布尔熊猫列
- vba - 如何将vba代码分成多行?
- reactjs - 带有反应导航的父堆栈导航器上的自定义标题
- python - 如何在*抽象语法树之前编辑解析树?
- python - 在类中定义的全局变量
- python - 使用 tf.keras.models.save_model() 保存多输入 TF 2.x 子类模型时出现 TypeError
- python - 代码不同部分的不同 QFileSystemModel 行计数值