streaming 相关问题

流式传输是通过网络将数字多媒体内容从提供商传递给消费者的过程。提供者可以存储数据或者可以从实时源中继数据。

React中的gRPC流无法按预期工作

我正在尝试在我的react应用程序中测试gRPC流。虽然我有一些麻烦。我们已经测试了盛开的流,并且每2秒成功地将事件流最多传输8个流。 ...

回答 1 投票 1

使用kafka进行流式处理,而无需在Hive中进行分析

我想做一个项目,在其中我会流一些推文以在Hive中进行分析,所有这些过程都必须在HDF / NiFi中完成。该项目必须是可伸缩的。我在Cloudera网站上看到人们采用两个...

回答 1 投票 0

Scala-如何从地图解析所有具有其Meta细节的json,并捕获无效json的错误消息

输入数据:{“ id”:“ 1”,“ a”:“ abc”,“ b”:“ bcd”,“ c”:“ cde”,“有效载荷”:“ Map(” path_1 / file1“ :“ {” a“:” abc“,” x“,” xyz“}”,“ path_1 / file2”:“ {” b“:” abc“,” y“,” xyz“}”,“ path_2 / file3“:” {“ c”:“ abc”,“ z”,“ xyz”}“,” ...

回答 1 投票 0

第99个百分位延迟和吞吐量的含义是什么

我已经读过一些文章,它们对Spark处理,Storm和Flink等流处理引擎的性能进行了基准测试。在评估部分中,标准是第99个百分点和吞吐量。对于...

回答 1 投票 1

如何在附加模式下写入流

当不带水印的流式数据帧/数据集上有流式聚合时,不支持获取错误输出模式。我想将输出放到控制台上。 class StructSpark:def ...

回答 1 投票 1

如何将流数据持久化到DolphinDB中的磁盘上?

默认情况下,流表将所有流数据保留在内存中。如何在DolphinDB中将流数据持久保存到磁盘?例如,我有一个流表,如下所示:n = 20000000 colNames =`...

回答 1 投票 0

如何在dolphinDB中发布表?

我在DolphinDB服务器中有一个如下表:n = 100000 t = streamTable(rand(100,n)作为id,rand(100.0,n)作为val)share t作为st;如何在客户端中获取数据,并且clint不是DolphinDB ...

回答 1 投票 1

Live Streaming Auto Pilot(实时循环播放视频)

直到现在,我在LiveStream.com上已有一个帐户。它有一个超级虚拟工作室,您可以在其中制作视频播放列表并以实时模式播放它们(它不像普通的播放列表,它不是从...开始的...

回答 2 投票 0

使用Jackson避免内部内存流式传输内部JSONArray记录

最近,Been试图深入研究如何通过HTTP端点流JSON内容,因为我不想在发送响应之前将整个JSON存储在内存中。但是,我对...

回答 1 投票 0

如何通过io.Reader转换HTML实体

我的Go程序发出HTTP请求,其响应主体是大型JSON文档,其字符串将&字符编码为&和&(可能是由于某些Microsoft平台的怪癖?)。我的...

回答 2 投票 2

进行流式处理时是否可以移动输出文件,而不会使Spark作业崩溃?

我有一个以Kafka为源运行的结构化流Spark作业,以附加模式输出orc文件。在作业运行时,我每隔某个特定的时间就将文件(想要)移动到hdfs位置...

回答 1 投票 0

SignalR同时流式传输

使用SignalR,您可以分别进行服务器到客户端和客户端到服务器的流传输。是否可以同时同时进行两种方式?假设我们有一些来自IoT设备的传感器数据,并且...

回答 1 投票 0

FFMPEG RTSP流式传输

我需要ffmpeg流式传输的帮助。我有一个Grandstream GSC3510扬声器,它也像电话一样工作。我需要配置rtsp服务器以流式传输1个文件或多个文件(如果可能)...

回答 1 投票 -1

Haskell流式传输-如何将原始流与结果流合并

使用Haskell流技术,我可以轻松地对流进行分组,并对每个组求和。 >>> S.print $映射的S.toList $ S.groupBy(\ xy-> x * y> 0)$每个[-1,-2,3,4,5,-6] [-1,-2 ] [3,4,5] [-6] ...

回答 1 投票 1

如何以流模式将数据从AWS RDS加载到Google BigQuery?

如何以流模式将数据从AWS RDS加载到Google BigQuery?说明:我在RDS(SQL Server)中有数据,并且想将该数据实时加载到Google BigQuery中。

回答 2 投票 1

RTSP到RTMP流或其他

我在IP摄像机上有一个RTSP流。我需要将此凸轮发布在网页上。我尝试了JWPlayer,但我认为jwplayer仅支持rtmp而不是rtsp。如果网页上不支持RTSP。I...

回答 2 投票 1

骆驼:如何使用StreamList从SQL组件流式传输a

我正在尝试使用Camels SQL组件使用outputType = StreamList从数据库进行流传输。我从使用ConsumerTemplate的Java类获得ResultIterator:public Flux CreateFlux ...

回答 1 投票 0

在上下文中使用大型生成器流式处理Django模板

我想在Django模板中呈现大型日志文件。为此,模板将呈现由生成器提供的各行,生成器从磁盘流式传输日志文件。模板渲染只是停止...

回答 1 投票 0

Flink状态与普通类变量之间的差异

我无法理解Apache Flink中状态的使用。据我了解,状态在Flink程序执行期间会保持变量值。我认为可以是同一件事...

回答 1 投票 0

哪个是Apache Spark DStream与HDFS序列文件中的静态数据记录联接的最佳方式?

我的目标是使用SparkStreaming监视用户输入。用户的输入是DStream,仅是数据记录(短字符串)的键。该程序需要过滤并读取静态数据集(非常大的RDD,...

回答 1 投票 -1

© www.soinside.com 2019 - 2024. All rights reserved.