《交流群》专题
-
ApacheFlink流连接使用数据流API，不输出任何内容
我有2个使用kafka主题创建的流，我正在使用DataStream API加入它们。我希望将连接（应用）的结果发布到另一个kafka主题。我在外部主题中看不到连接的结果。 我确认我向两个源主题发布了正确的数据。不确定哪里出了问题。下面是代码片段， 创建的流如下所示。 流连接使用等于的连接执行，如下所示。 如下所述， 有什么线索吗，哪里出了问题？我可以在拓扑中看到可用的消息，谢谢
-
YouTube流媒体API表示用户未启用实时流媒体
我正在使用Google的YouTube API Explorer（备用）来查找属于其他人的任意流媒体广播的信息。 无论我在字段中输入了什么，我都会返回 这似乎很荒谬，考虑到视频显然是流媒体。 我突然想到，我可能误解了字段的说明，所以我尝试了几种不同的可能性。这些包括。。。 频道ID（） 用户ID（） 视频ID（） ...每个都无济于事。 我如何询问一个频道有关其直播流视频的信息？这个问题在过去可以
-
如何在流批处理流连接中定义连接条件？
我使用的是SPARK-SQL-2.4.1V和Java1.8。和Kafka版本SPARK-SQL-KAFKA-0-10_2.11_2.4.3。 这会产生以下错误： 类型Dataset中的方法join（Dataset,String）不适用于参数（Dataset,String,String）
-
Spring Cloud数据流将参数传递给数据流服务器
-
我可以将一条流拆分为多条较小的流吗
除了这个用例，流还有很多问题 我有一个巨大的对象流
-
Twitter连接在流媒体数小时后挂起-流媒体API
目前我正在使用Streaming API（https://stream.twitter.com/1/statuses/filter.json）。 连接成功后，我会将服务器上的所有推文记录到数据库中。只有在运行了几个小时或几天没有问题后，问题才会出现，然后无法检索更多推文。如果我重新启动客户端，处理会恢复正常，一切正常，直到下一次挂起。
-
使用非流式应用程序/JSON的Spring WebFlux流量行为
我正在评估使用Spring Webflux，但我们必须支持期望Application/JSON，而不是Application/Stream+JSON的客户机。我不清楚Spring WebFlux如何在需要Application/JSON的客户机的情况下处理Flux的序列化。 如果一个Flux序列化为application/json，而不是application/stream+json，这是一个阻塞
-
如何在不关闭流的情况下从流量中收集
我的做法是创建一个反应endpoint，如下所示： 这会在数据可用时立即将其发回前端，然而，我的第二个用例是在数据到达时将其汇集到一个单独的集合中，这样，如果以后有类似的请求到达，我就可以从池中卸载整个数据，而不必再次访问服务。 在不关闭流量流的情况下，我有什么选择来访问流量并在它们到达时将值存储到集合中？ 遇到异常： java.lang.IllegalStateException:stream已
-
Spark结构流媒体-联合两个或多个流媒体源
这是因为检查点只存储了其中一个数据流的偏移量吗？浏览Spark结构流文档，似乎可以在Spark 2.2或>中进行流源的联接/联合
-
在Flink（浓缩）中结合低延迟流和多元数据流我正在评估Flink，用于流式分析场景，但还没有找到足够的信息，说明如何实现我们今天在遗留系统中所做的ETL设置。 一个非常常见的场景是，我们有一个键控的低吞吐量元数据流，我们希望使用这些数据流来丰富高吞吐量数据流，如下所示： 这就提出了两个关于Flink的问题：如何使用时间窗口重叠但不相等的缓慢更新流来丰富快速移动的流（元数据可以活几天，而数据可以活几分钟）？如何有效地将多个（最多10个）流与F
-
仅为kafka流中的左联接在右流中获取空值
我正在尝试加入两个Kafka主题的两个数据流。 每个主题都有一个key值对，其中key是整数数据类型，value包含字符串格式的json。来自这两个源的数据类似于下面的示例(key、value): 现在我正尝试基于ProductID左联接这两个流，因此所有这些记录的键都设置为ProductID。但不幸的是，我在连接的正确流值中不断得到空值。甚至连一条记录都没有正确连接。下面是我加入这两个记录的代码
-
将一个Kafka输入流动态连接到多个输出流
Kafka流中是否内置了允许将单个输入流动态连接到多个输出流的功能？允许基于true/false谓词进行分支，但这不是我想要的。我希望每个传入日志都确定它将在运行时流到的主题，例如，日志将流到主题和日志将流到主题。 我可以在流中调用，然后写给Kafka制作人，但这似乎不是很好。在Streams框架中是否有更好的方法来实现这一点？
-
流的限制不适用于基于字符数组[duplicate]的流
为什么下面的代码不将输出限制为前三个字符？ 输出: 我希望输出为：
-
Spring5WebResponsive-我们如何使用WebClient检索流量中的流数据？
当前里程碑（M4）文档显示了如何使用检索的示例： 我们如何使用WebClient将流式数据（从返回
-
使用jGit循环提交文件
问题内容： 在连接到仓库以及添加，提交甚至循环提交文件的消息方面，我已经设法掌握了jGit文件的基础知识。 我接下来要做的是能够获取单个文件的所有提交消息，然后能够将单个文件还原回特定的参考/时间点。 问题答案： 这是基于所有父提交查找提交更改的方法 （标量代码） 请注意，TreeFilter.ANY_DIFF适用于单个树遍历器，并将返回根提交中可用的所有元素。 然后，您将不得不遍历树以查看您的文