1回答
我们正在尝试处理具有IoT集线器、流分析和表存储的仪表板上的事件驱动图标(开/关/活动)。我不能让实际的进程在6秒内工作。流分析的水印是恒定的5秒。该网站声称即时处理。https://azure.microsoft.com/en-us/services/stream-analytics/ 我使用一个非常简单的查询来设置流分析，即将排队时间
浏览 28提问于2019-06-11得票数 0
回答已采纳
应用程序将监听实时数据流，开窗口(事件时间窗口)并处理每个键控流。我还有另一个用例，在这个用例中，我还需要能够支持回填某些密钥流的旧数据(这些将是带有event-time 考虑到我使用的是水印，这可能是一个问题，因为Flink不支持每个密钥的水印。因此，任何用于回填的键控流最终都将被忽略，因为此流的事件时间将是实况流维护的应用程序水印。
我也问过其他类似的问题，但没有找到可能的方法。发送到应用副本的数据
浏览 18提问于2021-11-01得票数 1
我正致力于理解Azure流分析中的水印。根据MS文档，有两种方法可以计算水印。
(5)估计到达时间= (1)
浏览 0提问于2020-07-06得票数 0
回答已采纳
1回答
我想了解的是，在火花中的结构化流的保留时间是多少。我有不同的火花结构的流流：
我的问题是:如何确保A流和B流中处理的数据不被丢弃
浏览 2提问于2019-12-12得票数 1
回答已采纳
1回答
假设我有一个数据流，其中包含事件时数据。我希望在8毫秒的窗口时间内收集输入数据流，并减少每个窗口数据。timeWindow(Time.milliseconds(8))Point数据流的关键是处理时间的时间戳映射到处理毫秒时间戳的最后但是，数据流可能到达较晚，并进入错误的窗口时间。例如，假设我将窗口时间设置为8毫秒。如果数据按顺序进入F
浏览 2提问于2018-07-14得票数 1
回答已采纳
我使用flink会话窗口连接两个流。 return System.currentTimeMillis();}
我测试了上面的代码以正确输出，水印和事件是正确的
浏览 3提问于2020-07-30得票数 0
回答已采纳
1回答
我的问题是，每当我在输入目录中添加第三批数据时，第一批数据将被处理并打印到控制台。为什么？drop("window") .outputMode("append") .startinput_tost_static.csv数据集如下：4,600有人能帮我
浏览 2提问于2019-01-26得票数 3
我阅读了关于状态实时的Apache文档。1).newBuilder(Time.minutes(60)).setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired)
valueStateDescriptor.enab
浏览 4提问于2020-10-03得票数 0
回答已采纳
我有一个包含事件Event(Id, Type, Date)的流，我想处理按(Id，Type)和活动会话分组的那些事件
Event1: Event(1, T1, 2018-01-24)} } .print()
这是处理历史事件和会话窗口的适当方法吗
浏览 1提问于2018-05-29得票数 5
回答已采纳
我正在开发一个android应用程序，它使用将DJI无人机的视频流发送到。视频是使用RTMP协议编码和发送的，使用SDK方法。由于使用ANT到WEBRTC，由于延迟非常低，我注意到了一个问题：
约2-3s后，潜伏期开始线性下降，每3-4分钟损失约1s。考虑到性能问题，我随后附加了，我注意到了一个非常奇怪的行为:附带了分析器，流性能就完美了。4-500毫秒的恒定潜伏期，即使在几个小时后也没有任何损失。如果我立即启动该应用程序并附带分析</
浏览 2提问于2020-09-15得票数 0
2回答
从s3位置触发2.1.1 (scala )流json文件。User类抛出异常:当流数据框架/数据集上存在流聚合时，不支持org.apache.spark.sql.AnalysisException:追加输出模式
这个错误看起来很奇怪，因为我没有进
浏览 1提问于2017-07-24得票数 1
回答已采纳
我们正在使用流分析从IoT集线器读取IoT消息。为了提高带宽利用率，我们希望以压缩格式发送数据。我知道，流分析支持gzip和deflate格式的输入流的解压缩，这是文档记录的。但是，在迁移期间，我们可能会让设备同时向IoT集线器发送压缩和未压缩的数据，并且我们必须处理两种格式/客户端版本。我在考虑在客户端消息中包含一个元数据属性，以指示有效负载是压缩的还是未压缩的，并使用IoT集线器路由到两个不同的流分析作业(一个读取压缩格
浏览 14提问于2019-11-06得票数 0
回答已采纳
我有一个C++计算机视觉应用程序连接到ffmpeg库，它提供从视频流到分析例程的帧。这种思想可以提供一个中等通用的视频流标识符，该视频源将被解压缩并将帧一帧一帧地传递到分析例程(这将运行用户的分析功能)。我在试图从流中获得可靠的时间戳时遇到了许多问题，因此我目前忽略了pts和dts。我知道忽略pts/dts对可变帧速率流是不好的。我打算稍后再特地处理他们。播放机目前检查最后解压缩的帧是否超过2帧(假设帧速率恒定)，如果是“丢弃帧”，则不会将其
浏览 2提问于2019-10-20得票数 2
回答已采纳
1回答
Kappa不需要批处理层，而是速度层必须保证历史数据重计算的计算精度和足够的吞吐量(更多的并行性/资源)。什么时候(由于Kappa架构)我必须插入数据到批处理服务层？如果流层不间断地向批处理和流服务层插入数据，那么延迟数据到达又如何呢？还是流</
浏览 7提问于2019-10-15得票数 7
回答已采纳
我一直在使用MediaElement来处理流的接收： AutoPlay="True"客户端上的用户可以向流服务器发送命令，这些命令可以更改流的内容，我们希望能够立即向用户显示更改的结果。然而，似乎有一个5秒的硬编码缓冲区长度，导致用户的操作和结果之间有5秒的恒定延迟。
浏览 3提问于2014-09-11得票数 0
4回答
数据流是实时的、恒定的流，也具有更少的部分。客户端显示此数据的波形，以及不需要立即更新的数据。还应该对客户端进行身份验证。我还在考虑非明文协议(我正在替换的当前协议是二进制协议)。Google protocol buffers看起来是一个处理低层细节的很好的候选者，但我不确定它是否可以在Android上使用。我很确
浏览 1提问于2010-01-17得票数 8
3回答
我想在手动终止程序时立即关闭流，这样做可以避免由于未关闭的流而丢失数据的风险。应该有一种方法可以通过异常处理来做到这一点，但我不确定。任何建议都是非常感谢的！
谢谢
浏览 0提问于2012-12-10得票数 0
回答已采纳
2回答
ad-hoc -函数边界-为了处理罕见的错误-在单个函数中的情况，其中其他的流控制方法是不切实际的，
为每个函数创建一个潜在的调用树(使用Eclipse/CDT)，而不是立即处理上面指出的抛出的异常手动分析调用树，并检查给定异常是否最终在相关边界之前得
浏览 3提问于2013-05-23得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
