streaming

1热度

2回答

返回到在线python编程指南： https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html 我没有看到任何有关像kafka连接器等流媒体编程的材料。也从git集线器的例子（https://github.com/apache/flink/tree/master/flink-examples/f

-7热度

1回答

添加长时间点击参数

我让这个应用程序从用户可以流从n艺术家的歌曲。在构建这个应用程序时，我一直只使用onclick属性。但是现在我想要长时间点击每个艺术家的名字，以便可以弹出一个关于他们的敬酒。任何人都可以帮助我有longclick选项。在此先感谢。

0热度

1回答

火花onQueryProgress复制

当监控结构化流传输的StreamingQueryListener，我发现复制在onQueryProgress override def onQueryProgress(queryProgress: QueryProgressEvent): Unit = { if(queryProgress.progress.numInputRows!=0) { println("Qu

0热度

1回答

如何将H.264编码器的实时流转换为Wowza等流媒体服务？

希望能够在流媒体问题上得到一些意见。我有一个H.264硬件编码器，您可以连接HDMI信号源（DVD播放器，电脑等），然后您可以通过在路由器中打开一个端口并设置一个端口forwading规则（在我的情况下，该设备的ip是172.16.16.121和端口使用3124）我已经设置了这样一个能够从编码器使用VLC>开放网络流>并键入我的公共IP url rtsp：//xxx.xxx.xxx.xxx：3

2热度

1回答

如何使用pipes-group实现流包中的fold和foldsM？

pipes-group库允许您在有效的流中分隔组，而无需随时在内存中保存整个组。从管的基团两个有用的功能是folds和foldsM：皱褶单子:: M =>（X - >一 - > X） - > X - >（X - > B） - >游离T（监制上午）MR - >生产者BMR foldsM ::单子米=>（X - >一 - > MX） - > MX - >（X - > mb）个 - >游离T （监

0热度

1回答

从麦克风流，添加效果并保存到wav文件使用tarsos android库

注：我使用的是android studio，目前我使用最新的tarsos audio library，它应该与android兼容，并且实际上已经成功添加该库到我的android studio项目。我以前尝试过使用JTransforms和Minim库，但没有运气。编辑8/23/17：找到并修复了一些错误，重新发布了当前代码，仍然没有取得进展，实际问题总结如下：摘要：在第5个代码块中，我发布了第1

1热度

1回答

Android将数据从ByteBuffer存储到存储

我使用第三方sdk广播流并添加回调后，我成功地获得了音频的ByteBuffer，但是当我将它保存到SD卡时无法播放它。这里是我的代码片段 long startedTime = -1; @Override public void onAudioBuffer(ByteBuffer byteBuffer, int i, long l) { if (bufferedOu

1热度

1回答

流星火异常“主”

我使用SBT使用Scala的火花试图流Twitter的数据，一切都顺利，但我有一个问题：这是我buld.sbt： import Assembly._ import AssemblyPlugin._ name := "TwitterSparkStreaming" version := "0.1" scalaVersion := "2.12.3" libraryDependencies

0热度

1回答

FFMPEG FishEye Equirectangular

我正在努力与FFMPEGs重映射筛选器。我有一个安全摄像头，流了一堆不同的选项，但默认情况下此鱼眼：我看到Ricotah西塔的地图的一吨，但没有显示我如何生成的地图文件的不同布局，就像我拥有的那样。我尝试过只做2个pano，但当我流到YouTube时，图像变得非常松散。有人能指出我正确的方向吗？

0热度

1回答

PetitFS流媒体阅读

这是一个非常愚蠢的/简单的问题：我使用Petit FS的arduino包装，我试图做一个流数据读入FIFO。图书馆表示，它支持流阅读，我需要通过缓冲= NULL来激活它，但我想不出我需要实现/重写/ Overrite而读来处理我的数据，方法/流任何人都可以帮我吗？没关系，在avr_mmcp文件中，是一个常量，它定义了一个用作流式传输函数的函数。不知道我是如何错过它的。