问题标签 [custom-receiver]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

52 问题
Newest
Active
Bountied
318
Unanswered
0 投票
0 回答
77 浏览

java - Apache Spark，带有自定义接收器的 Java 流挂起

我已经使用 java 流 api 编写了一个自定义接收器。它的目的是读取一个加密的文件，解密它，然后推送这些行以进行进一步的阐述。问题是，即使文件被正确读取、解密并推送到内存存储，我也无法开始流式传输。使流生成输出的唯一方法是优雅地停止火花流上下文。

这是我的 java 自定义接收器的一部分，我将解密的行放入存储中：

这是我访问接收到的流并尝试执行一些操作的地方：

使用此代码，进程挂起并且永远不会刷新文件系统上接收到的流。代码，除了自定义接收器和火花存储的使用与此示例非常相似： https ://github.com/apache/spark/blob/v3.1.1/examples/src/main/java/org/ apache/spark/examples/streaming/JavaSqlNetworkWordCount.java 我的代码中是否缺少某些内容？如何启动流式处理并将数据集写入文件系统？任何帮助表示赞赏，谢谢。

0 投票
0 回答
42 浏览

javascript - 如何在 ChromeCast Web 接收器中使用自定义数据对象

我正在尝试将自定义 JSON 对象发送到 Chromecast 接收器应用程序，MediaData 代码是这个

这里我想读取和使用通过 setCustomData 传递的数据，如何在 Chromecast 网络接收器中做


12345678910