- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
作为一名 Java 开发人员,我习惯使用 Spring Batch 进行批处理,一般使用流式库导出大型 XML 文件,以 StAX 为例。
我现在正在开发一个 Scala 应用程序,想知道是否有任何框架、工具或指南来实现批处理。
我的 Scala 应用程序使用 Cake Pattern,我不确定如何将它与 SpringBatch 集成。另外,我想遵循 Functional programming in Scala
中描述的指南。并尝试使用 IO monad 之类的东西来保持功能的纯度......
我知道这是一个悬而未决的问题,但我从未读过有关此的任何内容...
有人已经在这里实现了功能批处理吗?它是如何工作的?我应该有一个在 IO monad 中创建批处理操作并运行它的 main 吗?是否有任何工具或指南来帮助、监控或处理可重启性,例如我们在 Java 中使用 Spring Batch。
你在 Scala 中使用 Spring Batch 吗?
您如何处理集成部分,例如等待 JMS/AMQP 消息开始生成 XML 的处理?
欢迎对 subjet 提供任何反馈
最佳答案
你没有提到你正在用 Scala 开发什么样的应用程序,所以我在这里猜测一下,假设你正在做一个服务器端的应用程序。进一步猜测假设您正在使用 Akka ...因为您正在使用它,不是吗? :)
在那种情况下,我猜你要找的是 Akka Quartz Scheduler ,Akka 中用于 cron 样式调度的官方 Quartz 扩展和实用程序。我自己没有尝试过,但根据您的要求,Akka + 这个模块似乎很合适。考虑到 Akka 已经提供了处理失败 actor 的可重启性的钩子(Hook),而且我认为利用内置在 actor 中的生命周期回调添加对批处理过程的监控并不是那么困难。
关于与 JMS/AMQP 消息的交互,您可以使用 Akka Camel module ,它支持通过许多协议(protocol)(包括 JMS)发送和接收消息。使用这个模块,您可以让消费者参与者从某个 JMS 端点接收消息,并从那里触发您想要的任何进程,可能会将新消息转发或发送给负责该进程的参与者。如果进程由 cron 样式计时器或传入消息触发,您可以重用相同的参与者来完成任务。
关于scala - 批处理和函数式编程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19609949/
我正在尝试打印 timeval 类型的值。实际上我可以打印它,但我收到以下警告: 该行有多个标记 格式“%ld”需要“long int”类型,但参数 2 的类型为“struct timeval” 程序
我正在编写自己的 unix 终端,但在执行命令时遇到问题: 首先,我获取用户输入并将其存储到缓冲区中,然后我将单词分开并将它们存储到我的 argv[] 数组中。IE命令是“firefox”以启动存储在
我是 CUDA 的新手。我有一个关于一个简单程序的问题,希望有人能注意到我的错误。 __global__ void ADD(float* A, float* B, float* C) { con
我有一个关于 C 语言 CGI 编程的一般性问题。 我使用嵌入式 Web 服务器来处理 Web 界面。为此,我在服务器中存储了一个 HTML 文件。在此 HTML 文件中包含 JavaScript 和
**摘要:**在代码的世界中,是存在很多艺术般的写法,这可能也是部分程序员追求编程这项事业的内在动力。 本文分享自华为云社区《【云驻共创】用4种代码中的艺术试图唤回你对编程的兴趣》,作者: break
我有一个函数,它的任务是在父对象中创建一个变量。我想要的是让函数在调用它的级别创建变量。 createVariable testFunc() [1] "test" > testFunc2() [1]
以下代码用于将多个连续的空格替换为1个空格。虽然我设法做到了,但我对花括号的使用感到困惑。 这个实际上运行良好: #include #include int main() { int ch, la
我正在尝试将文件写入磁盘,然后自动重新编译。不幸的是,某事似乎不起作用,我收到一条我还不明白的错误消息(我是 C 初学者 :-)。如果我手动编译生成的 hello.c,一切正常吗?! #include
如何将指针值传递给结构数组; 例如,在 txt 上我有这个: John Doe;xxxx@hotmail.com;214425532; 我的代码: typedef struct Person{
我尝试编写一些代码来检索 objectID,结果是 2B-06-01-04-01-82-31-01-03-01-01 . 这个值不正确吗? // Send a SysObjectId SNMP req
您好,提前感谢您的帮助, (请注意评论部分以获得更多见解:即,以下示例中的成本列已添加到此问题中;西蒙提供了一个很好的答案,但成本列本身并未出现在他的数据响应中,尽管他提供的功能与成本列一起使用) 我
我想知道是否有人能够提出一些解决非线性优化问题的软件包的方法,而非线性优化问题可以为优化解决方案提供整数变量?问题是使具有相等约束的函数最小化,该函数受某些上下边界约束的约束。 我已经在R中使用了'n
我是 R 编程的初学者,正在尝试向具有 50 列的矩阵添加一个额外的列。这个新列将是该行中前 10 个值的平均值。 randomMatrix <- generateMatrix(1,5000,100,
我在《K&R II C 编程 ANSI C》一书中读到,“>>”和“0; nwords--) sum += *buf++; sum = (sum >>
当下拉列表的选择发生变化时,我想: 1) 通过 div 在整个网站上显示一些 GUI 阻止覆盖 2)然后处理一些代码 3) 然后隐藏叠加层。 问题是,当我在事件监听器函数中编写此逻辑时,将执行 onC
我正在使用 Clojure 和 RESTEasy 设计 JAX-RS REST 服务器. 据我了解,用 Lisp 系列语言编写的应用程序比用“传统”命令式语言编写的应用程序更多地构建为“特定于领域的语
我目前正在研究一种替代出勤监控系统作为一项举措。目前,我设计的用户表单如下所示: Time Stamp Userform 它的工作原理如下: 员工将选择他/她将使用的时间戳类型:开始时间、超时、第一次
我是一名学生,试图自学编程,从在线资源和像您这样的人那里获得帮助。我在网上找到了一个练习来创建一个小程序来执行此操作: 编写一个程序,读取数字 a 和 b(长整型)并列出 a 和 b 之间有多少个数字
我正在尝试编写一个 shell 程序,给定一个参数,打印程序的名称和参数中的每个奇数词(即,不是偶数词)。但是,我没有得到预期的结果。在跟踪我的程序时,我注意到,尽管奇数词(例如,第 5 个词,5 %
只是想知道是否有任何 Java API 可以让您控制台式机/笔记本电脑外壳上的 LED? 或者,如果不可能,是否有可能? 最佳答案 如果你说的是前面的 LED 指示电源状态和 HDD 繁忙状态,恐怕没
我是一名优秀的程序员,十分优秀!