《stream》专题
-
使用reduce(3parameters)函数传递集合-streams java 8
我试图用Java8的流计算前面两个值的乘法。我想调用一个将返回数组/列表/集合的函数。我正在创建一个列表，并向其添加1,2。 假设列表名是result。 简言之；我想传递一个有两个值的列表，让函数找到前两个值(1，2)的乘法，并将其添加到列表中，然后找到后两个值(2，2)的乘法，并将其添加到列表中，直到流达到极限。
-
使用stream Java 8获取属性数组、属性数组（嵌套属性）
如何做到这一点，以这种简单的方式？
-
Java 16的stream.tolist（）和stream.collect（collectors.tolist（））的区别？
（这个问题类似于stream.tolist（）会比collectors.tolist（）表现得更好，但侧重于行为，而不仅仅是性能。）
-
Streams peek（）的未来等价物是什么？
这里的答案引用了一个包含所有完全未来方法的表，但这并不是我要找的，或者我可能搞错了。 我正在寻找Streams'peek（）的完全未来等价物，因此基本上是一个返回输入参数的，或者一个不返回的。我认为有两种方法都不能在语义上准确地表达我的意图，但可以做到这一点： 和 两者都从上一个阶段获取输入，允许我执行一个操作并以相同的类型返回到下一个阶段。在这两种方法中，后一种方法将我的时间限制在其他事情完成时
-
对不起，此视频在Http streaming android中不能流到此设备
我可以流一些视频从URL（服务器）成功， 但其他的（我的视频到我的服务器）不是。 P/S：三星Galaxy Tab 7“-2.2.1 谢谢，
-
如何将Spring WebClient get Application/Octet-Stream作为主体输入流处理？
我正在下载带有GET请求的文件。其中有些相当大，所以我希望将它们作为一个流来获取，并在能够处理它们时以块的形式读取字节，而不是在内存中读取整个文件。 WebClient看起来很合适，但我遇到了“UnsupportedMediaTypeException：内容类型'application/octet-stream'不受支持”。 下面是一些简短的示例代码。 这里是堆栈跟踪的一大块。 ...... 我确
-
StreamSets JDBC查询使用者-未定义列。ColumnName=0
我需要使用Streamsets将Phoenix表中的记录转换为JSON文件。出于内部POC的目的，我试图从Phoenix中提取一个简单的文件。起源是指向Phoenix的JDBC查询使用者，目前，它直接连接到本地FS目的地。当然，在实际实现中，中间还会有一些组件，比如Jython evaluator。 它验证得很好。但是当我尝试运行它时，我得到以下错误： null
-
无法将java.util.Optional与stream转换
-
Kafka Streams：状态存储分区错误
定义了一个自定义存储，用于自定义变压器（参考下面）。 https://github.com/apache/kafka/blob/trunk/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java 我得到以下例外。不确定，为什么内部主题“test_01
-
kafka streams中全局状态存储的分区数
在kafka中的全局状态存储是否总是一个分区，或者我们可以为全局状态存储更改日志主题设置多个分区？ 我找不到任何关于这方面的明确文件。
-
Kafka Streams-流线程开始处理之前的全局状态存储恢复
我有全局状态存储附加了我的拓扑。全局状态存储在从压缩主题读取中。这个全局状态存储存储了100,000条记录，这些记录应该在状态存储中，以便正确处理拓扑。 问题：Q.在应用程序重启期间，kafka streams将启动全局状态存储线程，并确保在启动streams线程之前已完全构建状态？ 我试图找到一些留档相关的这个主题请指出我的代码或留档也。
-
Kafka Streams全球商店-添加更改日志主题
我需要维护自己的全局表结构。基本上，全局存储与处理器相连，我使用一些计算来创建键，然后将其存储到键值存储。 由于全局状态存储没有更改日志主题，所以它使用原始主题作为更改日志。在状态恢复的情况下，它只是将主题数据加载到全局表（这将是错误的），因为我们构建了自己的密钥 我的要求是用我的自定义键（不是直接来自主题的键）创建一个全局存储。有什么解决方案吗？ 下面的链接回答了我的问题Kafka stream
-
在Kafka Streams中指定映射操作上的serdes
我很抱歉，如果这是一个重复的帖子，但我一直在寻找答案，到目前为止什么也没有得到。 我需要的是在更改Kafka Streams中的键类型的映射操作期间指定serdes。原始KStream有一个字符串类型的键和avro（通用记录）值，但我需要将其重新映射到avro键和值。大致如下： 我相信我需要指定serde，因为类型正在改变，但是我在地图操作符上找不到方法。当从主题读取、分组或写回主题时，我们通常可
-
Kafka Streams：为执行KTable-KTable外键连接的应用程序增加主题分区
我找到的大部分信息都与主键连接有关。我知道外键连接对于Kafka流来说是一个相对较新的功能。我对它的规模感兴趣。我知道Kafka Streams并行性受到每个主题上的分区数的限制，但是我对增加输入主题分区意味着什么有一些疑问。 外键联接对共分区输入主题有相同的要求吗？也就是说，两个主题是否需要具有相同数量的分区 在应用程序在生产环境中运行数月或数年后，如何添加分区？支持每个KTable的chang
-
在Kafka Streams应用程序中，第二个输出流不再被写入
我目前正在实现一个Kafka Streams应用程序，其中我正在阅读一个主题并进行一些处理。在处理过程中，我将其分为两个流，一个写入一个主题（Avro模式），另一个是计数聚合（字数计数），将键/值对（字符串/长）写入另一个主题。代码之前运行良好，但最近第二个流不再编写。 在此代码示例中： 句子流（）编写正确，但单词计数分组出现了问题： 我真的不明白为什么不再写了。 也许有人能提供一些帮助？我很乐意