在BroadcastHub的例子中，可以动态地产生监听同一个生产者的工作者。但这种派生必须在代码中显式完成。我想知道它是否可以被编码为流中事件的反应。在下面的示例中，我想在收到spawns流中的“产卵”消息后再产生2个工作进程。有可能吗？
浏览 1提问于2017-02-10得票数 0
回答已采纳
1回答
我想创建一个基于另一个元素流的列表流。每当列表中的元素发出新值时，List Stream都应该生成一个新列表。getModelStream(id).listen((event) { }); yield models;但是它总是会产生一个空数组我认为问题可能在于它不会对事件监听器做出反应。
你是如何处理这种问题的？
浏览 15提问于2021-12-03得票数 0
我有一个Esper语句列表，我想在Apache流中运行这些语句。如何确保对所有消息的所有语句进行评估？
是否需要为每个Esper语句(即: esper:// .)有一个单独的路由？注意:每个语句可能在不同的时间产生一个结果(例如，聚合超过1秒，另一个在5秒内，等等)。
浏览 5提问于2015-08-19得票数 0
回答已采纳
1回答
我很难理解NotUsed和Done在Akka流中的目的和意义。让我们看看以下两个简单的例子：implicit val system = ActorSystem("akka-streams")使用Done
implicit val system = ActorSystem("akka-streams</e
浏览 4提问于2017-10-24得票数 5
回答已采纳
1回答
YouTube直播流覆盖
、、、
我正在尝试实现一个YouTube直播流覆盖:活动流是一个体育事件，我需要放置一个覆盖与事件的实时评分。以下是问题：
是否有可能使用JavaScript添加覆盖客户端？是否有可能在实时添加字幕以模仿与分数重叠的内容？
浏览 2提问于2013-07-21得票数 2
回答已采纳
1回答
我有一个单独的Bison解析器定义，可以应用于多个流。每个流以一定的间隔以块的形式产生，因此我想保存给定解析实例的状态，以便在不同的流之间切换，同时保持每个解析实例的状态(及其相关堆栈)。我知道有可能在扫描器的几个缓冲区之间切换，但这对我为正在分析的每个流构建不同的解析树没有帮助。
是否有任何Bison功能允许执行yy_switch_to_buffer()在flex中执行的功能
浏览 0提问于2013-06-12得票数 1
回答已采纳
1回答
我有一个使用案例，其中有一个Kinesis流(在不同的AWS帐户中管理)，是否可以使用可能在我们的帐户(跨帐户)中触发lambda的事件来配置此流？我知道在Kinesis events的情况下，lambda会轮询Kinesis流，那么它的工作原理是否类似于帐户A中的S3事件(基于推送)如何触发帐户B中的lambda？此外，这两个资源是否应该位于相同的区域才能正常工
浏览 0提问于2018-08-04得票数 0
2回答
排列星河数据集列
、、、
我正在使用Spark2.3.1的结构化流API。是否有可能在火花流数据的列中对值进行排序？我尝试使用下面的代码，然后在异常消息之后意识到流上下文不可能遍历整个窗口。, row_number().over(Window.orderBy($"transactionTime")))
org.apache.spark.sql.AnalysisException:流数据框架/数据集不支持非基于时间的窗口。
浏览 0提问于2018-07-06得票数 4
回答已采纳
2回答
我试图用akka-streams的Tcp客户端向数据库发送一个查询，但我不明白我缺少了什么。
因此，我有两种类型的Query和Response，它们完全可以与akka的ByteString进行转换。因此，假设源是我对查询的请求，我无法找到向查询源提供这个流的最佳方法，而是像Source(Future.successful(query))一样构造它，并将它连接到流source.via(flow)，这给了我另一个在这里，我无法理解如何获得Future[Response]，尝试了几个组合子，但是它给了我Mate
浏览 2提问于2015-09-16得票数 1
回答已采纳
1回答
流处理和批处理
、、、、
由于批处理的延迟是在累积特定数目的数据时产生的，我是否可以将“一的大小”的批处理视为流处理？或者当运算符进行计算时还有其他的区别吗？例如，如果我将基于火花的程序的批处理大小设置为1，是否可以使其延迟降低到flink？我的一种想法是:对于流处理，如果处理了前一个操作符，一个数据流就会从前一个操作符流到后一个操作符，但是对于批处理过程，只有在操作符处理完一个数据之后，它才能接受另一个数据。流处理中的流水线似乎是加速的关键
浏览 9提问于2022-11-14得票数 0
2回答
多年来，我一直在研究如何从我的电脑上创建音乐流。我看过程序，但我看到的任何有用的东西都是Windows (我使用Mac)。
最后，我对溪流的运作方式产生了兴趣。是否有任何方法可以创建自己的流，可能在PHP中使用套接字函数？这里有一个PHP库吗？
浏览 6提问于2008-09-05得票数 5
我有一个Planning系统，它从客户订单中计算出某种全局Schedule。当客户向此系统下订单或撤销订单，或计划中的事件使用的某些资源不可用时，此计划会随时间而改变。现在，另一个系统需要知道Schedule中某些事件的状态。Planning系统给了我一个akka-streams Source[Schedule]，它在计划更改时发出一个Schedule，我还有一个Source[StatusRequest]，从它接收StatusRequest，以及它是否实际实现了我的需求(参见上面的粗体文
浏览 1提问于2018-07-16得票数 0
回答已采纳
2回答
我真的很喜欢xpdf，但我想有一个基于标签的工作流。如果我用xpdf file.pdf打开一个pdf，然后用xpdf file2.pdf打开另一个pdf，那么scond文件将在xpdf的一个新实例中打开。是否有可能在xpdf的第一个实例中将其作为一个选项卡打开？
我在OSX上。
浏览 0提问于2019-02-11得票数 1
1回答
我试图读取一个文件夹中的文本文件，并通过两个工作流程读取内容。是否有可能在另一个工作流中调用工作流？path { }Foreach并行只接受工作流。
浏览 1提问于2016-09-27得票数 2
回答已采纳
2回答
我想知道我们是否可以有一个父工作流，当被调用时会产生多个子工作流。我们是否可以在SharePoint中实现它呢？因此，基本上，我想使用父工作流的一部分来触发另一个工作流--这个特定的工作流可以关联到同一个列表，有时它们可以与引起任何问题的不同列表和libraries...will相关联。所以我希望它能起作用
假设某些东西触发工作流A时，它会在SharePoint列表中生成多个项目，
浏览 0提问于2019-08-13得票数 0
回答已采纳
2回答
一种方法是在每次完成后向Actor发送一条消息，当Actor验证所有流都准备就绪时，它就可以触发该操作。我想知道在akka-streams Scala DSL中是否有我忽略的东西，这会使它变得更简单。
编辑：将流转换为未来将无法工作，因为正如文档所提到的，未来是在流中发生的第一个事件之后完成的。
浏览 5提问于2014-08-15得票数 7
我有一个传感器，它将数据从IOT集线器发送到流式分析，只有在一个脉冲，而不是在一个正常的间隔。[ "pulses": 2.0,
"windowend": "1970-01-01T12:02:00.0000000Z是否有可能每分钟从发送常规数据流，即使没有传入消息？
浏览 3提问于2017-10-26得票数 0
回答已采纳
我有一个STM32F051驱动一个H桥(适当的门驱动器和过流脉冲发送回微控制器)，使用TIM1和互补信号(和死区时间产生)为变压器供电。我试图配置不同的“安全”状态，具体取决于所接收的过流脉冲：
其思想是提高逆变器的过流性能。是否有可能在接收到GPIO上的脉冲时，手动将定时器的输出设置为定义状态？我试过使用safe函数
浏览 8提问于2020-10-15得票数 0
回答已采纳
我有一个HLS流，流与嵌入ID3 PRIV标签的实时提要，以标记流中的某些点。是否有可能在Safari中通过Javascript从这些标记中获得通知或以某种方式检索数据？
浏览 0提问于2015-05-19得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
