我在MySQL中有数据库，我不知道如何将它导入Apache进行流处理。然后从消费者那里得到数据。请给我一些建议。
浏览 5提问于2016-06-30得票数 6
1回答
.net中的数据流处理
、、、
我正在学习一些产品来实现事件源和一般的数据流处理。特别是，我发现Apache非常适合在多个微服务之间流我的所有事件，但我想处理所有这些数据，以便计算实时输出。我发现Apache可能是适合我的产品，但问题是用Java编写的，您应该用Java编写计算代码。您知道在.NET世界中是否有类似的东西，一个处理实时流、保持计算状态的框架，多少像Apache所能做的那样？或者你对我能用C#替代做什么有什么建议吗？
谢谢
浏览 4提问于2022-07-21得票数 0
1回答
方案中流的空间复杂性
、、、、
我正在阅读结构和解释计算机程序(SICP)，并希望确保我的想法是正确的。考虑使用递归定义的以下简单流： (cons-stream n (integers-starting-from (+ n 1)因此，当我们沿着这个流进行cdr-stream时，会创建嵌套的lambda函数，并存储用于计算lambda函数的帧链。这些框架是必要的，因为lambda函数计算表达式，并在包围帧中找到它们。因此，我假设为了计算
浏览 1提问于2020-01-25得票数 5
回答已采纳
如何测量Apache Spark和Flink的能耗有没有什么工具或技术可以测量Spark和Flink的能耗
浏览 1提问于2020-09-01得票数 0
1回答
我正在与RTSP服务器和相机用户MFC工作，我必须流相机和客户端将使用VLC实时观看相机。我花了一周时间在谷歌上阅读文件和搜索。我知道我应该为摄像机子类live555编写一个框架源，对框架进行编码，然后使用live555对其进行流。但我不知道怎么写帧源相机。
任何文档、示例链接等。你可以给我。
浏览 0提问于2014-06-30得票数 1
2回答
排列星河数据集列
、、、
我正在使用Spark2.3.1的结构化流API。是否有可能在火花流数据的列中对值进行排序？我尝试使用下面的代码，然后在异常消息之后意识到流上下文不可能遍历整个窗口。, row_number().over(Window.orderBy($"transactionTime")))
org.apache.spark.sql.AnalysisException:流数据框架有人能帮我计算等级/百分位吗？
浏览 0提问于2018-07-06得票数 4
回答已采纳
1回答
最近，我开始使用GCP工作流和函数。我们为函数使用了无服务器框架，我们可以在计算机上使用serverless invoke local --function <function_name>命令在我们的计算机上运行它们，这样我们就不需要花费云执行了我现在正在寻找的是，是否有一种方法可以对GCP工作流做同样的事情，在我们自己的计算机上运行它们，而不是在云中调用它们。
浏览 9提问于2021-07-27得票数 2
我希望对表计算进行建模，并允许用户使用拖放方框图来定义计算工作流。具有图形用户界面的块模拟的Python框架(如OpenModelica、LabView)
浏览 0提问于2023-06-01得票数 0
我将流时间基设置为1/25，但在调用avformat_write_header之后，它的值为-18082736/1。在每个帧中，当我打印流time_base时，它表示1/12800，而编解码器的time_base总是正常的(1/25)。
浏览 3提问于2015-04-24得票数 5
回答已采纳
2回答
跨各种属性聚合的最佳技术栈
、、、、
流数据被输入到流中的系统。我们正在考虑打破时间桶(例如5分钟)中的流数据，并根据不同的属性预计算各种聚合，并将聚合存储在DynamoDB中以服务查询。关于这一点，我们正在评估以下备选方案：
如果有人使用过类似的用例或使用过上述任何技术，请让我
浏览 4提问于2013-03-13得票数 0
回答已采纳
1回答
python异步调用远程对象方法
、、、、
还有其他的框架和工具可以做同样的事情吗？
服务器是用zmq编写的，但我愿意将它更改为不同的解决方案。
浏览 8提问于2017-11-02得票数 0
回答已采纳
2回答
给定两个编码流，我希望将它们并排连接起来。假设我有两个独立的H.264编码的1024x768视频，具有相同的帧率。我想把这两个结合起来，使视频1和视频2并排形成一个宽度为(1024*2)x768或2048x768的两倍的流。我的第一个想法是对流进行解码，并合并各个帧，然后重新编码单个流。问题似乎在于将帧从YUV转换为RGB或将它们组合成YUV形式的计算时间。Android解码器产生YUV，用于并排组合帧的数学运算对于这种形式来说是密集的。所以我的问题是：
1)如果框架是YUV形式的，有没有更快或更有效的方
浏览 17提问于2017-08-07得票数 0
回答已采纳
0回答
我想在Soot中执行数据流分析。但我的分析的本质是，它将执行一次正向分析迭代，然后使用在正向分析中计算的数据流值执行一次反向分析迭代。这两次迭代变成了我的分析技术的一次迭代。如果不是，那么我需要在Soot框架中做哪些更改。如果在JAVA中有其他可用于数据流分析的工具，那么有人可以告诉我吗？曼达尔
浏览 7提问于2016-07-05得票数 1
我对UICollectionViewFlowLayout进行了子类划分，在该子类中，我将更改UICollectionViewLayoutAttributes框架，以便它们看起来更大或更小--这取决于它们在屏幕上的位置layoutAttributesForItemAtIndexPath中返回它:在shouldInvalidateLayoutForBoundsChange中返回YES：
一切运行良好，但单元格没有动画的变化的框架
浏览 0提问于2014-04-07得票数 7
回答已采纳
我计划编写一个批处理分布式计算系统，它将使用大约10-20台计算机。系统某些部分的数据流约为50 1GB，而其他部分的数据流则要小得多~1GB。但是，我有些怀疑，因为它似乎是为更大的数据量和可能更多的计算机而优化的。例如，书Hadoop的权威指南明确提到：
多年来，高性能计算(HPC)和网格计算社区一直在使用消息传递接口(MPI)等MPI进行大规模的数据处理
浏览 0提问于2013-04-28得票数 0
回答已采纳
1回答
当前设置：火花流作业处理卡夫卡主题的timeseries数据。大约每秒钟都会有不同的传感器输入新的数据。此外，批处理间隔为1秒。利用updateStateByKey()将有状态数据作为一种新的流进行计算。一旦这些有状态的数据跨越一个treshold，就会在Kafka主题上生成一个事件。将这些在一个批处理中移动到updateStateByKey()，就会在结果流上为该键生成一个计算值。
当然，这是不可接受的，因为大量的数据点被减少到一个单一的数据点。将在实时流上生成的警报事件不会出现在重新计算的流上。所以用这种方法来比较算法
浏览 2提问于2016-11-09得票数 0
3回答
我刚刚开始学习web/网络编程(因此不确定什么信息是相关的)，但我的目标是将由计算机X获取的流视频播放到计算机Y上的网页上，以尽可能接近实时。我目前有一个尴尬的解决方案，它几乎可以满足我的需要，根据这个方案，在计算机X上获得的视频通过UDP套接字发送到Y计算机。我的问题很简单，那就是是否有可能在webRTC框架中直接读取UDP流(不知怎么读，如果有的话)，而不是笨拙地通过网络摄像头读取。
浏览 2提问于2018-05-16得票数 3
回答已采纳
可能的原因是工作流定义中的non-deterministic workflow definition代码或incompatible change。可能的原因是non-deterministic workflow definition代码或工作流定义中不兼容的更改。“
任何帮助都将不胜感激。
浏览 4提问于2017-09-22得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号