您知道在Apache Storm中，您可以让Spout将数据流式传输到多个螺栓。有没有办法在Apache Spark中做类似的事情？我基本上希望有一个程序从Kafka队列中读取数据，并将其输出到两个不同的程序，然后这两个程序可以用自己的不同方式处理它。x将处理数据以计算一种类型的指标(在我的情况下，它将计算用户活动)，而y将计算另一种类型的指标(在我的情况下，这将是基于不同设备的检查活动)。
有人能告诉我这是怎么在Spark中实现的吗？
浏览 0提问于2015-09-24得票数 4
1回答
我正在编写一个星星之流应用程序，与我在每个计算节点中广播的基本数据相比，该应用程序具有在线流式数据。但是，由于基本数据每天更新，我也需要每天更新广播变量。基本数据驻留在hdfs上。
有办法这样做吗？更新与任何在线流媒体结果无关，比如每天早上12点。此外，如果有这样的方法，更新过程是否会阻止流计算作业？
浏览 1提问于2016-02-15得票数 1
回答已采纳
由于我们只计划实现75-100个客户端，我们计算出，我们需要两个具有双8C处理器的服务器和一个共享存储服务器。此计算基于ORACLE的一篇论文，即每个核心有12台活动虚拟机。但是刀刃还有一些其他的优点：还有其他优势，我们应该考虑，以弥补价格--这种优势是否如此重要，我们应该考虑投资于刀刃吗？
浏览 0提问于2012-12-07得票数 1
回答已采纳
1回答
消费者会做民意调查吗？或者会有一些活动吗？例如:一个实时跟踪应用，用户可以流式传输他们的详细信息，这样其他用户就可以看到他们的位置，在这个例子中，一些用户流式传输了他们的位置，而另一些用户则使用了它。
有什么建议吗？
浏览 0提问于2016-04-17得票数 0
关于嵌套for循环的使用，我有几个问题。在本书的这个例子中，它使用嵌套的for循环来绘制一个典型的棋盘。1)当我假设下面的代码说绘制棋盘方块的顺序是从左到右垂直向下直到整个棋盘绘制完成时，我的理解是正确的吗？
2)我对最内部的for循环中的双x和双y的用途有一些疑问。它们的计算目的是为了将一个方块间距到另一个方块吗？你能展开双x和双y的用途吗，以及一个循环的每个循环会发生什么？
浏览 2提问于2012-11-14得票数 0
回答已采纳
2回答
我有一个网站，那里有更多的竞选活动。就像在特定日期范围内的双点战役一样。例如：End Datetime - 2016-06-20 12:00Start Datetime - 2016-06-10 12:00然后，当
浏览 3提问于2016-06-15得票数 0
回答已采纳
据我所知，有两种获取宽度的方法：
getView().getViewTreeObserver().addOnGlobalLayoutListener...有什么好办法解决这个问题吗？
浏览 2提问于2015-03-12得票数 1
如果我有一个具有1 1PFlop/s单精度浮点功率的GPU服务器，我能做双精度计算吗？如果是的话，计算能力相当于双精度计算吗？
浏览 6提问于2022-10-23得票数 -2
1回答
我需要从网页上使用用户摄像头来流式传输现场活动。我的想法是使用getUserMedia()从用户摄像头获取视频并将其发送到RTMP点，这是可能的吗？还是有其他方法可以做到这一点？
浏览 1提问于2015-06-30得票数 3
1回答
巨矩阵的特征值
、、
我有两个50,000 x 50,000对称实矩阵A和B(双精度)，它们是非稀疏的(55%非零)。B是正定的.我有一个广义特征问题:A=B在平均12 GB内存的计算机上，我还有什么选择来计算它们吗？
浏览 2提问于2014-05-19得票数 0
回答已采纳
1回答
在windows7中，有通过网络组传输媒体的选项。它是已知协议吗？(例如，我的电视支持这种流媒体，所以我相信这是已知的协议)
你知道我该怎么做吗？
浏览 2提问于2012-11-18得票数 2
回答已采纳
1回答
考虑到要在K2000 GPU卡上执行的GPU内核函数(计算能力3.0)，如下所示：__global__ void PerformSomeOperations(float另外，如果我有N个块，这是否意味着每个块的共享内存将被N除以？
浏览 1提问于2013-11-01得票数 1
对于一个简单的12个月预测，我使用的是12个月双移动平均。我已经设法通过查询1(下面)获得了单个移动平均线。基于查询1创建的表，我编写了另一个查询(查询2)，以获得双移动平均值。我的问题是:在一个查询中，有什么方法可以计算双移动平均值吗？ SELECT A.*, IIf([A].[VOL]>0, INTO [
浏览 0提问于2012-11-20得票数 4
2回答
关于大小数
、、
我有一个csv文件，其中金额和数量字段存在于除标题和尾部记录之外的每个详细记录中。尾部记录有一个总费用值，即明细记录中数量乘以金额字段的总和。对于所有这些计算，我都使用双精度数据类型
在csv文件数量字段中显示为"10.12“、"10”、"10.0“、"10.456”、"10.4555“或"-10.12”。数量可以是正值，也可以是负值。当我在网上搜索时，我知道双精度可能会给财务计算带来问题，所以需要使用BIGDECIMAL。但我
浏览 3提问于2010-03-01得票数 1
回答已采纳
1回答
更改后的文件在网页界面中显示得相当快，但在我的第二台计算机的Ubuntu-One文件夹中却没有显示出来。有人知道怎么加快速度吗？
浏览 0提问于2011-12-19得票数 1
1回答
我已经使用C++和OpenGL用简单的3d第一人称演示设置了一个演示，它似乎工作得相当好。我的目标是:当用户将相机指向一个平面并单击鼠标左键时，我希望绘制从玩家位置指向相机所面对的方向的光线与该平面的交点。class Vector public: {
this->x =
浏览 1提问于2013-02-27得票数 2
我正在尝试使用以下代码获取steps & jobMetrics信息(是一个活动的流式作业)：
val jobMetrics = dataflowClient.projects().jobs().getMetrics对我做错了什么有什么建议吗？
浏览 4提问于2022-01-27得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
