问题标签 [sink]

我一直在尝试使用 Spring XD将数据从Mail提取到File 。虽然流的创建是成功的，但在此过程中没有创建输出文件。

我使用的命令如下：

我能做些什么来解决这个问题？

此外，当我使用Mail as Sink时，也会出现同样的问题。在我所做的示例中，我使用HTTP作为我的Source。

我使用的命令如下：

非常感谢您的反馈！

我正在使用 spooldir 源将 .gz 文件从 SpoolDirectory 移动到 HDFS。我正在使用以下配置，

===========================

=========================================

所以文件确实会传输到 HDFS，但它会在末尾附加 time_in_millis.gz 扩展名。此外，当我尝试在 HDFS 中压缩文件（通过终端复制）时，它会在其中显示未知字符。所以不确定发生了什么。

1. 我想在传输到 HDFS 后保持相同的文件名
2. 我希望能够解压缩文件并读取内容

有人可以帮忙吗？

我是 R 语言的新手。我正在用 R 在 spark 中编写程序。我想将输出保存到 hdfs 路径。我尝试了该sink方法

但它会引发错误。任何帮助将不胜感激。

确切的错误信息是

我想计算http post body的哈希值并在接收时同时解析它，所以我需要一个这样的函数：

当我开发图像上传时，我passthroughSink以类似的方式使用。但在这种情况下，我不需要将图像保存到文件的管道的结果。

一般来说，我知道如何使用类似 MVar 的东西来实现 fork，但我不确定这是否是最佳解决方案。

我有一个小的 Python 脚本来设置 PulseAudio，以便 Festival 语音合成程序可以将合成的语音传输到 Skype 呼叫中。这是为了让无法说话的人能够在常规的 Skype 小组会议上发言。

它可以工作，但是要使设置正常工作需要与 PulseAudio 音量控制 GUI 进行大量交互。如何通过终端中的脚本设置 PulseAudio 流？

小脚本如下：

我编写了一个流程，通过Hortonworks提供的自定义水槽源和Flume Kafka接收器生成消息以写入Kafka 代理。 在此过程中，我注意到如果 KAFKA 代理已经在运行，然后我启动我的 Flume 代理，它会正确地将每条消息传递给 Kafka 代理，但是当我在 Flume 代理已经运行时启动 Kafka 代理时，KAFKA 代理无法接收所有消息。 当我运行Kafka 控制台消费者来检查收到的消息计数时，我注意到它从一开始就丢弃了很少的记录，从结尾丢弃了很少的记录。

我在Flume.conf中尝试了多种混合和匹配，但它仍然按预期工作。

以下是我提供给 Flume.conf 的配置参数 -

我还尝试分析水槽日志并注意到水槽指标正确显示了PUT和TAKE计数。

请让我知道是否有人有任何解决此问题的指示。
提前感谢您的帮助。

我有一个数据框。当我使用以下命令时，我想将其内容写入 outputfile.txt：

我收到以下消息：

如何将此数据帧的所有内容直接写入 txt 文件？

我想一个接一个地打印到相同的 txt (outfile.txt) 文件项。例如，首先我想将一个数据框打印到 outfile.txt - u。之后，写了一条消息“你好”，最后是模型摘要。我该怎么做？sink(outfile.txt)适合这种情况吗？

如何将输出重定向到某个 txt 文件，但是以这样的方式，以便我可以在控制台中同时看到该输出，同时逐步生成？

我一直在使用以下代码将节点设置为接收节点。现在，使用此代码，只有第一个节点被设置为接收器。如果我想设置在网络中检测到的第一个节点，例如，第 3 个节点作为接收节点，那么该怎么做呢？另外，您能否解释一下第 1 行中“if”语句的含义，我认为这将有助于我解决查询。

1. 如果（rimeaddr_node_addr.u8[0] == 1 && rimeaddr_node_addr.u8[1] == 0）
2. {
3. printf("我是水槽\n");
4. collect_set_sink(&tc, 1);
5. }