当前位置: 首页 > 知识库问答 >
问题:

从pCollection输出多个文本文件

酆阳煦
2023-03-14

如何从pcollection > 输出到多个文件?

每个条目中的关键字是文件名。groupByKey转换给了我pcollection >> ,但是我如何将它们写入多个文件呢?

例如,给定以下输入

<file1, value1>
<file2, value2>
<file1, value3>

我想输出两个文件

file1:
  value1
  value3

file2:
  value2

共有1个答案

穆阳炎
2023-03-14

Dataflow目前没有可以为您完成此操作的转换。作为解决办法,您可以使用一个简单的dofn,它将从kv中提取文件名,使用IoChannelFactory打开文件,并将Iterable 写入其中。

看类似的问题和另一个。

我们计划解决https://issues.apache.org/jira/browse/beam-92,但还没有具体的时间表。

 类似资料:
  • 问题内容: 我正在尝试获取一个示例,该示例使用XSLT 2.0来输出工作中的多个文件。 在Java 1.6上使用Saxon B 9.7.0.1,出现此错误: input.xml transform.xml 问题答案: URI中的字符20是“文档和设置”中的第一个空格。作为快速解决方案,请尝试将文件移动到没有空格的路径。(例如,“ C:\ test”或类似的代码。)我怀疑长期的解决方法是将XSLT更

  • 问题内容: 所以我在打印输出时遇到麻烦。我理解这个概念,但是当涉及到这个问题时,这有点奇怪。我尝试了不同的打印行,所有这些行在控制台窗口中都给我不同的结果。我仍在尝试不同的方法,但即时通讯开始用尽想法。谢谢,非常感谢! 这就是我想要的预期输出。 当我尝试println时,它对output.println(data [0]); 当我进行常规打印时 这是文本文件打印方法` 问题答案: 试试这个 :

  • 我需要输出5-8行到我的窗口。我用一个TextArea实现了这一点,但我不希望用户能够在其中写字,也不能使用键盘在按钮和页面上的其他元素之间导航。 假设有一个名为text的String,您认为我应该将其写成哪种字段类型?文本很好,但只允许我使用一行。 由于我使用FXML设计菜单页面,因此相关部分是: 基本上,我设法从ping测试中获得信息,并将其添加到数组列表中

  • 问题内容: 我有20个线程用println()函数写入一个名为result.txt的文件。我该如何同步它们? 我注意到每次我的程序运行时,results.txt中的文本行数都会不同。 谢谢。 问题答案: 通过包含同步方法以写入文件的类访问文件。一次仅一个线程将能够执行该方法。 我认为Singleton模式适合您的问题: 每次需要写入文件时,只需调用:

  • 我想上传多输入文件。我尝试了下面的代码,但文件没有上传,我无法获得上传目录。 HTML 控制器 我也尝试用下面的代码获取上传的数据,但为什么总是出现错误?

  • 我使用的是saxon for xml到html的xslt转换,我需要两个输出文件,一个是基本html,一个是javascript文件,如果不支持js,它可以是文本文件。这是我的转换c#代码,也是xsl文档的一部分。我需要从转换后的xml输出一个html文件和一个带有脚本的javascript文件 这里是xsl文档的一部分