1回答
将Spark流数据发送回客户端
、、、、
我是Apache Spark Streaming的新手。我正在开发一个spark流应用程序，以找到最短路径，并再次将该路径发送回客户端。我已经编写了获取数据并使用函数处理数据的代码，但我有一个问题，如何将结果再次发送回客户端以下是我的代码： import networkx as nxfrom pyspark.streaming im
浏览 11提问于2020-04-27得票数 0
回答已采纳
2回答
我想将Nifi流文件发送到Spark，并在Spark中进行一些转换，然后再次将结果发送回Nifi，以便我能够在Nifi中进一步操作。我不想写流文件写到数据库或HDFS，然后触发火花作业。我想直接发送流文件到星火和接收结果直接从火花到尼菲。我试过在Nifi中使用ExecuteSparkInteractive处理器，但我被卡住了。任何例子都会有帮助。
浏览 1提问于2018-10-31得票数 8
回答已采纳
2回答
将Kafka中的流数据“导入”到HBase中的最佳实践是什么？
使用案例如下:将车辆传感器数据流式传输到Kafka。然后，必须对这些传感器数据进行转换(即，将protobuf反序列化为人类可读的数据)，并将其存储在HBase中。1)您推荐哪个工具集(如Kafka --> Flume --> HBase、Kafka --> Storm --> HBase、Kafka --> Spark Streaming
浏览 1提问于2015-08-18得票数 6
1回答
我正在监视客户端和服务器之间发送的流量，发现了一些奇怪的东西。客户端使用以下密件将应用程序数据发送到服务器: TLS_PSK_WITH_AES_128_GCM_SHA256。GCM从1开始，然后服务器用nonce 1发送数据，然后客户端用nonce 2发送数据，服务器用nonce 2发送回数据，等等。
这是正确的吗？难道现在不是两次都一样吗？
浏览 0提问于2015-06-10得票数 1
回答已采纳
我的客户不想卷入复杂的OAuth流。我已经向他们提供了一项服务。我的客户将简单地向我的服务名称“”请求回发URL (在那里我可以将XML数据发回给他们)。我将代表用户获取所有数据，然后将其转换为XML文档，并使用post回发URL将其发回。然后社交媒体将代码发送回重定向URL
在同一个请求中
浏览 2提问于2017-08-24得票数 0
回答已采纳
1回答
您能提供一些关于使用Python使用Azure Service Bus流消息的建议吗？因为我发现Azure Service Bus没有spark结构化流源，所以在这种情况下，我可以使用提供的Python客户端读取Azure Service Bus消息，然后从Python客户端读取每个消息并将其写入Kafka主题，在这个Kafka主题上，我将应用spark结构化流编程。我的用例是使用Azure Service Bus流消息，并通过将其转
浏览 0提问于2021-03-09得票数 0
所以我有一个问题，卡夫卡辛克斯在星火流，同时发送JSON到多个主题和不可靠的卡夫卡经纪人。kafkaSink.value.send(kafkaTopic, strJSON)
当镜像代理关闭时，整个流应用程序都在等待它
浏览 0提问于2018-06-07得票数 1
基本思想是当客户端通过example.com:80连接到我的网站时，控制器将检查文件名并将其发送回客户端。但是，我希望这些数据通过端口11311发送到客户端。以下是我想要做的事情的简单解释：
这个是可能的吗？我正在使用HttpWebR
浏览 4提问于2013-10-31得票数 0
1回答
现在，我想获取这些值，使用Spark处理这些值，并将结果返回给用户。就像这样：详细的设置并不重要-星火流可以做一些建议或预测，可以坐在Databricks之上；后端可以是一个烧瓶应用程序.我的问题是：
这条管道漏掉了哪些碎片？一些中间DB，如Redis/Mongo/SQL？像卡夫卡这样的信息经纪人？我不能让我的头脑围绕着星火流将信息发送回网站后
浏览 0提问于2018-06-16得票数 3
2回答
用于NRT数据应用的Google
、、、、
我正在评估Kafka/Spark/HDFS，用于开发NRT (子秒级) java应用程序，该应用程序接收来自外部网关的数据，并将其发布到桌面/移动客户端(使用者)，用于各种主题。同时，数据将通过用于分析和ML的流和批处理(持久)管道提供。
独立的TCP客户端从外部TCP服务器读取流数据。客户端根据数据包(Kafka)发布不同主题的数据<
浏览 2提问于2016-02-16得票数 0
1回答
存储与动态控件相关的数据的最佳选择是什么。这是我的设想。GridView.Master's动态控件可以是TextBox、DropDownList、ListBox、类型的，但是页面在同一会话中会发生许多回发。作为更有经验的用户，您建议从数据库中填充这些控件中的项，还是允许每个控件的viewstate维护项目列表？我从更快的性能角度来看待这个问题。此外，请您提供您的建议的理由。
任何其他建议也是受欢迎的。
浏览 1提问于2009-12-28得票数 1
回答已采纳
OnClientClick事件调用将执行回发的方法，然后关闭窗口。该代码在IE中运行良好，但不会在Chrome中进行回发。两种情况下窗口都关闭。这是我的密码。btnExit_Click" OnClientClick="javascript:return closeMainWindow(this);" />
如果有更好/不同的方式执行服务器端代码，然后关闭浏览器窗口，我将非常感谢您对如何在
浏览 4提问于2013-08-21得票数 0
回答已采纳
1回答
gRPC是否支持服务器和客户端之间的以下通信方案? 1.客户端连接到服务器并调用waitMessages等方法。那么客户端只是在等待来自服务器的一些消息。2.服务器不定期向客户端发送消息。例如，客户端的某个方法被调用。3.客户端与服务器断开连接
我不喜欢通过轮询服务器来实现这个方案。我想调用一次服务器方法，然后等待消息。
浏览 0提问于2019-10-13得票数 0
1回答
我的理解是Spark Streaming序列化闭包(例如map、filter等)，并在工作节点上执行它(如所解释的)。是否有某种方法可以将结果发送回驱动程序，并在本地计算机上执行进一步的操作？在我们的特定用例中，我们试图将Spark生成的结果转换为可观察的流(使用RxScala)。
浏览 1提问于2015-03-05得票数 0
1回答
我使用Spark2.2.0。问题试图通过创建自定义接收器来回答非结构化流和scala的问题。 .format("s3-sqs") \ .option("queueUrl", .然而，如何直接发送流到火花流还
浏览 3提问于2017-12-28得票数 15
回答已采纳
然而，在fork()和exec()作为目标服务程序之前，它设法将这个双向套接字转换为三个标准I/O描述符STDIN、STDOUT和STDERR。我想到了以这种方式问这个问题，因为它可能会为我如何将“联接”文件描述符0、1和2重新放到一个套接字中提供线索。
浏览 1提问于2013-08-12得票数 1
我正在开发一个web服务接口，其中我的WCF应用程序既可以作为客户端，也可以作为服务。有多个Java客户端需要连接到我的web服务。我将需要接受的图像和文件流，并发送回转换后的图像流。我还需要连接到其他Java服务，以将图像流作为有效负载发送到数据库中。我是web服务的新手，有没有很好的文档介绍如何在WCF和Java客户端之间启用流式合同，反之亦然。如果我想将其他信息连同(组)图像流一起返回给<em
浏览 4提问于2011-12-14得票数 0
webapp需要额外长的时间来处理某些REST请求(对数据库的查询时间很长，然后在获得数据库响应后生成一个摘要)。在当前实现下，即使REST客户端停止请求，也仍在处理查询，直到数据库查询完成，响应被发送回并发现输出流已关闭。另一方面，we应用程序不会在很长时间内发回任何内容，导致Apache会话超时(我们将5分钟配置为超时)。那么，实现以下目标的最佳做法是什么：
浏览 0提问于2017-09-11得票数 1
编辑:我知道如何禁用jquery和的控件--这不是，我的问题是，为什么当我在客户端禁用它时，它背后的代码仍然具有真正的功能？
浏览 4提问于2012-06-25得票数 0
回答已采纳
是否有可能迫使Apple达尔文流服务器通过端口80发送流，是否有可能迫使Apple达尔文流服务器通过端口80发送流？
背景:我们有一个客户端，它通过3G/edge网络连接到我们的流媒体服务器。另外，客户端报告说来自YouTubes流服务器的流确实工作，我猜YouTubes流服务器通过端口80发送流数据。因此，是否可以从端口80 (可能与
浏览 0提问于2010-02-10得票数 2
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
