《stream》专题
-
如何在包含列表对象作为值的映射上迭代，并使用Java8 Streams将这些对象作为单独的列表对象获取
有两类： 对此有什么建议吗？
-
如何在单分区kafka主题上运行多个应用程序实例的ktable-ktable-joins-kafka streams应用程序？
对于我的应用程序，我使用KTable-Ktable连接，这样无论何时在主数据流或子数据流上接收数据，它都可以为所有三个表设置带有setters和getters的复合对象。这三个传入流具有不同的键，但是在创建KTable时，我为所有三个KTable设置相同的键。 我有一个分区的所有主题。当我在单个实例上运行应用程序时，一切都运行良好。我可以看到compositeObject填充了所有三个表中的数据。
-
Kafka Streams中的metadataForKey方法为连接到同一组的多个应用程序实例提供了错误信息
我正在实现一种机制，通过从存储区本地请求元数据信息或请求远程Kafka Streams实例来提供元数据信息。 我正在使用Scala和kafka-流-版本2.4.1的scala库 我将试着给你一个简单的例子来说明我在做什么 我正在运行Kafka集群，它创建了一个带有2个分区的测试主题 我还运行了1个Kafka Streams实例，正如我前面提到的，它实现了从存储中请求本地或远程元数据的机制，并保存所
-
使用自定义收集器时的Java 8 Stream-NullPointerException
我已经通过实现收集器接口并重写其方法实现了一个自定义收集器。收集器实现如下： 以下是我的Person类：
-
只有在我的RDD中的所有分区都已处理后，如何在Spark Streaming中接收输入？
假设我有一个JavaDStreamRecencer，它每秒从Spark Streaming中的TCP/IP套接字连接接收一个整数。然后我将其存储在列表中，直到我有100个整数。之后，我想将该RDD划分为4个分区，在我的电脑中每个内核一个，并在paralel中映射这些分区。所以类似于这样： 这是我的问题。我想实现一个FILO模型，在该模型中，我接收一个新输入，将其放置在RDD的第一个分区中，并从RD
-
如何在Java中使用stream（）方法将List转换为JSONArray的整数
我试图找到最好的方法来转换列表的整数到JSONArray的org.json.JSONArray库API调用。 鉴于 需要JSONArray对象 在Java中使用stream（）方法。
-
在Spring Cloud Data Flow中部署现有的Spring Cloud Stream
目前，我“手动”编排这3个组件，但我希望使用Spring Cloud Data Flow(SCDF)来创建流，并能够更好地操作它们。 根据SCDF文档，任何SCS应用程序都可以直接用作要在流中定义的应用程序。除此之外，应用程序的属性可以通过外部属性文件提供。但是，我提供了我的'application.yml'属性文件，但它不起作用： 经过一些研究，我意识到文档声明任何应用程序的任何属性都必须以这种
-
如果自动启动设置为false，如何手动启动Spring Cloud Stream绑定器
-
spring-cloud-starter-stream-source-file处理后删除文件
我试图利用spring-cloud-starter-stream-source-file app（https://github.com/spring-cloud-stream-app-starters/file/tree/master/spring-cloud-starter-stream-source-file）轮询一个目录，并将文件引用发送到定制处理器进行进一步处理。
-
SCDF自定义Spring-Cloud-Stream源应用程序不将生成的消息写入Kafka主题
我用kafka绑定器创建了一个简单的spring cloud流“源”和“汇”应用程序，并在SCDF（spring cloud Data Flow）中注册了JAR。 在SCDF（source-app sink-app）中创建了steam，并成功地部署了该流。 我的源应用程序很简单，代码如下： 在类级别上使用了@EnableBinding(Source.class)、@RestController。
-
使用Java Stream API的分层过滤
-
比stream.peek（）更好的方法
Edit:是我现在正在做的事情，但是由于只是返回，所以这似乎是对Map的误用。另外，它读起来并不像是商业逻辑。 最后编辑：我接受了@Holger的回答。不能期望处理流上的所有元素，因为它不是终端操作。也是如此。即使您可能已经终止了您的流，以保证它将处理所有操作，您也不应该编写期望每个用户都这样做的代码。因此，要进行处理，您应该在上使用，然后根据需要再次开始对进行流式处理。
-
Java8与Java9中的stream.peek（）方法
在IDE上执行程序时，它不会给出任何输出。我原以为它会给出。
-
spring cloud函数webflux+spring cloud stream是否与http源代码集成
我正在尝试将spring cloud stream与spring cloud函数webflux集成 https://cloud.spring.io/spring-cloud-static/spring-cloud-function/1.0.0.release/single/spring-cloud-function.html 从cloud stream中，我可以看到源代码需要定义为供应商https
-
找不到txt文件StreamReader
'未处理的异常： 系统。IO. FileNotFoundException：找不到文件"/Logins.txt"发生' 大家好，新手在xamarin c#中使用Systsem中的StreamReader创建了一个非常基本的登录/注册系统。IO读取包含存储用户名和密码的文本文件。txt文件与位于同一目录中。cs文件本身，并在解决方案资源管理器中可见。我尝试了完整的路径，但没有成功，我以管理员的身份运