《stream》专题
-
Flutter：带有StreamBuilder的FirebaseAuth（v1.2.0）无法在Flutter Web中进行热重新加载
所以在过去的几周里，我一直在测试FirebaseAuth的网页版和Android版，体验都很糟糕。我已经尽可能多的添加信息给你足够的背景。 我的目标 我的最终目标是制作一个包来简化Flutter中的FirebaseAuth。基本上，StreamBuilder在FirebaseAuth的authStateChanges流上运行，它在用户登录后或当我重新加载整个页面(Flutter Web)时立即给出
-
使用Stream从List中查找匹配昂贵条件的最后一个元素
我有一个大约一百万个元素的有序，我正在寻找与特定条件匹配的最后一个元素，但是条件计算起来很重，所以如果我从头开始会更好。总是有大致 匹配元素，最小值为 1。 我可以手动操作： 有没有办法用< code>Streams来写这个，这样< code > heavyConditionPredicate 就不用对列表的每个元素进行测试了？如果heavyConditionPredicate计算起来不那么重，我
-
如何使用lambdas/streams将嵌套的对象列表转换为映射(map)
我正在使用两个for循环将下面的对象结构列表转换为一个HashMap,如下所示。 我如何使用lambdas/streams做同样的事情呢？我试过用平面地图，但没用。流式传输时无法访问嵌套得注册区域. 基于@Nidhish Krishnan答案更新工作代码示例
-
从嵌套列表中获取最大值并使用stream转换为一个列表
-
在这种情况下，为什么Streams API需要泛型类型的提示？
无法编译以下内容： 特别是，使用javac编译时，错误将是： 但下面的汇编很好： 唯一的区别是我引入了一个额外的变量。请注意，我没有施法，所以没有语义变化。 有人能解释为什么需要这样做吗？
-
Apache Samza和Apache Kafka Streams之间的区别（关注并行性和通信）
在Samza和Kafka流中，数据流处理是在处理步骤（在Samza中称为“dataflow graph”，在Kafka流中称为“topology”）的序列/图（在Samza中称为“job”，在Kafka流中称为“processor”）中执行的。 假设我们有一个非常简单的工作流程，由一个工作者a组成，该工作者a消耗传感器测量值并过滤所有低于50的值，然后是一个工作者B，该工作者B接收剩余的测量值并过
-
Java 8 Streams：如何一次性调用collection.stream（）方法并检索具有不同字段的多个聚合值的数组
我将从Java8中的流API开始。 我测试了和的解决方案，并计算了每个解决方案的运行时间。 看来解决方案比更有效。 的解决方案似乎比我的解决方案（使用多个流）节省不了多少时间。
-
如何在Java中使用stream对一个列表中的两个相邻元素进行比较和操作？
背景是我有两个字符串类型变量str1和str2作为输入。最后，我必须返回一个列表，其中包含str1的连续前缀，该前缀小于Str2中的相关前缀。 但我发现我既无法操作一个列表中的两个相邻元素，也无法获得一个指针来比较和遍历列表中每个元素（元素是字符串类型）中的每个字符。 那么有没有什么方法可以操作一个列表中的两个相邻元素，这样我就可以比较它们在相同位置的字符。
-
计算Stream的元素
我想数一数一条流的不同元素，我想知道为什么 不行，日蚀告诉我 类型收集器中的方法toMap（Function，Function，BinaryOperator）不适用于参数（（s）- 顺便说一句，我知道这个解决方案： 所以我有两个问题： 我的第一个方法有什么错误 编辑：我自己解决了第一个问题： Java需要一个函数作为第二个参数。
-
如何在Spark Streaming 2.3.1中将每条记录写入多个kafka主题？
如何在Spark Streaming 2.3.1中把每条记录写到多个kafka主题？换句话说，我得到了5条记录和两个输出kafka主题，我希望这两个输出主题中都有5条记录。 这里的问题不谈论结构化流媒体案例。我正在寻找特定的结构化流媒体。
-
为什么累加器在Stream：：reduce中是一个双函数，而不是像组合器那样是一个二进制运算符？
为什么方法中的accumulator参数是而不是像combiner参数那样的。 为什么它的类型？为什么是？应该是？
-
为什么Stream.Reduce采用BinaryOperator而不是BiFunction？[副本]
对于我的具体情况，我想在约简中使用函数合成；例如： 这有一个编译错误： 相反，我需要做的是： 但是，这就失去了composition提供的无点样式。 为什么流API是这样设计的？是，所以用超类型声明方法的参数不是更有意义吗？
-
Spring Cloud Stream Kafka Streams入站KTable可预测的内部状态存储主题名称
我们正在使用带有Spring Cloud Stream函数的Kafka Streams。我们有一个典型的示例应用程序，它将用户单击与用户区域结合在一起。 我们知道，在定义拓扑结构时，我们可以通过使用适当的方法来强制内部变更日志或重新分区主题的自定义名称，这些方法接受物化存储的名称： 但是对于输入的KTable，我们不能更改它的状态存储内部主题名称，我们总是得到这个主题名称： 如果我们完全按照代码创
-
有没有办法根据大小刷新Kafka Streams的Windows Store？
我正在使用将从kafka主题读取元组的DSL应用编程接口编写Kafka Streams应用程序。在拓扑结构中，我想批处理元组。然后如果（1）30秒已经过去或（2）批处理的大小超过1 GB，我想将浴写入磁盘上的文件。 我写的拓扑使用TimeWindowedKStream对元组进行分组。然后调用聚合并传递窗口存储。 我的问题是，当国有商店试图写入Kafka变更日志时，我得到了一个 组织。阿帕奇。Kaf
-
使用kafka streams创建包含多个聚合的新KStream
我正在发送JSON消息，其中包含有关web服务请求和对Kafka主题的响应的详细信息。我想在每条消息到达Kafka时使用Kafka流进行处理，并将结果作为持续更新的摘要（JSON消息）发送到客户端连接的websocket。 然后，客户端将解析JSON，并在网页上显示各种计数/摘要。 示例输入消息如下所示 随着信息流进入Kafka，我希望能够实时计算 ** 请求总数，即所有请求的计数 invocat