回答情况：
提问时间：
问题标签：
1回答
3)然后用户决定两件事中的一件：“点击提交”，这将把所有的数据和流接收到服务器，或者如果他/他点击“下一步”，他/他可以查看下10条记录等。
是一个很好的整体解决方案，尤其适合上面的2)和3)吗？是否只获取部分数据并暂停流，然后继续、消耗并重复该过程？
浏览 0修改于2014-07-01得票数 0
2回答
我们的目标是接近连续处理每一个设备的数据，并计算最后一个小时的平均值等。最后，我们希望它发送一个通知，如果它超过一定的水平。
有哪些好的替代流处理工具是灵活的和可伸缩的？
浏览 7提问于2022-03-24得票数 1
1回答
toList.foreach(x => println(s"+++ $x"))came insidecame inside+++ 4+++ 2+++ 4基本上是一个接一个的处理，直到满足<6的终止条件。我猜这是我的"tolist“方法，它首先创建一个巨大的列表，然后才处理它。
浏览 9修改于2016-08-25得票数 1
回答已采纳
3回答
我需要处理来自一组流的数据，独立于其他流对每个流应用相同的细化。有没有像storm，spark streaming或samza这样的框架来实现这一点？
浏览 4修改于2015-12-03得票数 1
1回答
当流上处理的某些值为真时，我创建了一个异步处理块，以便将消息发送给JMS。但是，我必须选择应用于这个异步块的策略。queued-asynchronous-processing-strategy或
The asynchronous-processing-strategy.在文档中，他们说，当“出于某种原因，您不希望在节点间分发处理
浏览 2提问于2015-08-06得票数 0
回答已采纳
4回答
我有一个Map<String,List<String>>，并希望将其转换为Map<String,List<Long>>，因为列表中的每个String都代表一个Long：Map<String,List<Long>> output= .stream()
.collect(toMap(Entry::getKey, e -> e.getValue().strea
浏览 2修改于2019-10-22得票数 9
2回答
)print(stream_error.getvalue())
我有三个处理程序然后有一个用于控制台的Stream处理程序。然而，在这里，logging.debug和logging.info消息在控制台上被忽略，尽管设置的级别显式地足够低？！
浏览 6提问于2015-06-25得票数 1
回答已采纳
我试图使用流将JsonObject值放到自定义的ArrayList中我将流映射到JsonObject
.map有人知道我如何使用gson库来处理这个问题吗？用stream#collect而不是stream#forEach来回答也很好
浏览 0提问于2018-10-29得票数 0
回答已采纳
2回答
我正在使用Amazon的Flow框架for Java开发一个相对简单的工作流。我认为我对现在发生的一切都有很好的把握，但是我还有一个不确定的地方:我该如何处理超时呢？我的工作流的主要超时是工作流本身上的executionStartToCloseTimeoutSeconds，但我可以想象，无论触发哪种超时，流程都是相同的。似乎大多数时候，当任务超时时，它就会消失。
浏览 0修改于2015-09-03得票数 1
回答已采纳
1回答
由于批处理的延迟是在累积特定数目的数据时产生的，我是否可以将“一的大小”的批处理视为流处理？或者当运算符进行计算时还有其他的区别吗？例如，如果我将基于火花的程序的批处理大小设置为1，是否可以使其延迟降低到flink？我的一种想法是:对于流处理，如果处理了前一个操作符，一个数据流就会从前一个操作符流到后一个操作符，但是对于批处理过程，只有在操作符处理完一个数据之后，它才能接受另一个数据。流</
浏览 9提问于2022-11-14得票数 0
1回答
我需要处理数据有两个目的:将所有数据保存在DB中并将一些数据发送到RabbitMq。{"Ticker"："MSFT"，"DateTime"：'2019-05-14T10
浏览 0提问于2019-05-14得票数 5
回答已采纳
1回答
我使用RXJava实现了一个简单的数据分析功能，其中主题订阅者异步处理发布到主题的数据，将输出保存到Redis。 analyser.process(message); }}
在实现其他处理部分时我尝试过的一种方法是根据每种类型过滤列表，并分别处理它们，但这看起来很糟糕，我认为不能并行工作。如何并行处理它们？
浏览 1修改于2015-08-07得票数 1
我试图为我的Spring3.2.0、Spring、JSF2.1.12应用程序实现异常处理。到目前为止，我可以使用异常处理程序流捕获大多数异常： <if testNoSuchFlowDefinitionException和类似的问题，如果我很清楚的话，它们发生在流执行之外。有人知道如何处理这些例外吗？
此外，我还需要
浏览 6修改于2013-05-29得票数 0
我编写了一个函数，在给定Stream[Long]的情况下，它将过滤出大于4,000,000的数字。 @tailrec case Stream() => acc case a #:: as if(a >
浏览 4提问于2014-03-21得票数 1
3回答
我艰难地发现，JVM只使用一个线程池来并行处理流。我们在一个大的流上有一个I/O阻塞的函数，这会导致与不相关的并行流一起使用的不相关的快速函数的活跃性问题。
流上没有允许使用备用线程池的方法。
浏览 1修改于2015-02-14得票数 3
2回答
with some ints//process the stream in some way
我的问题是，是否可以保证流的处理顺序与底层
浏览 2修改于2016-07-08得票数 6
2回答
我正在设计一个系统，其中有一个主要的对象流，并且有多个工作人员，从这个对象产生一些结果。最后，有一些特殊的/唯一的工作人员(从图论的角度来说是一个“接收器”)，它接受所有的结果，并将它们处理到某个被写入到某个DB的最终对象。
假设W_B依赖于W_A，如果W_B由于某种原因而关闭，那么流将停止，系统将停止工作。值得一提的是，它不是一个实时应用程序，而是一个离线处理系统(
浏览 1提问于2018-11-22得票数 7
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号