当前位置: 首页 > 知识库问答 >
问题:

在talend大数据工作岗位上创造历史序列

汤弘文
2023-03-14

我有一个在塔伦德创建序列的要求。基本上,记录来自源文件。对于每个源行,我希望创建一个唯一的数字。这就是事情变得复杂的地方。当第二天出现新文件时,talend应该选择最后生成的数字,然后用1递增它。对于EX:今天,最后生成的序列号是100。明天talend应该从100生成序列号。即101,102,103,104....这意味着talend应该保留以前生成的最后一个序列号的历史记录。

谢谢

共有1个答案

卫嘉言
2023-03-14

因此,在这种情况下,您必须将最后一个序列值保存在目标数据库(如果有的话)或专用文件中的某个地方。如果记录存储在数据库中,则还可以使用适当的select从相应的字段中获取最大值。
当您获得所需的值时,需要将其存储在全局变量中,然后重用该变量以使用以下内容初始化序列:
numeric.sequence(“yoursequence”,(Integer)globalmap.get(“yourglobal”),1)希望这能有所帮助。

 类似资料:
  • 有没有一种方法可以在talend大数据工作中迭代一个TiveInput?

  • 任何push到open-falcon中的数据,事后都可以通过api组件提供的restAPI,来查询得到。 具体请参考API文档

  • 任何push到open-falcon中的数据,事后都可以通过api组件提供的restAPI,来查询得到。 具体请参考API文档

  • 我正在开发一个应用程序,希望在实时事件和过去事件上运行Flink SQL。我尝试了一个POC,其中Flink在Kafka等流源上运行SQL,SQL查询只返回新的事件/更改。但是,我想对所有数据运行SQL,有些数据可能会随着时间的推移而改变。基本上我的要求就是连续查询整个数据。如何通过Flink或其他流媒体解决方案实现这一点?

  • 问题内容: 我想使用Vim来查看结果(不在shell中)。我认为可以使用(将的结果用作的输入),但返回结果为: 有人可以解释吗? 问题答案: 通过传递到 vim中 ,您正在更改标准输入流。由于 vim 是交互式程序,因此它需要标准输入作为控制台。 如果要在vim中查看,应该告诉它您正在从stdin中读取文件(通过提供参数): 另外,您可以使用 更多 或 更少 : 后两者是优选的。如果通过管道 传送

  • 我正在使用泽西开发一个API,并希望将其准备好部署到Google App Engine。但是,当我在Postman上测试时,GET函数有效,但POST函数无效。我只收到一条简短的错误消息,即“错误415不支持的媒体类型”,我无法确定哪里出了问题。 请求资源类 请求服务等级 网状物XML 提前感谢所有帮助我指出并解决问题并回答我问题的人。