Generating Separate Output files in Hadoop Streaming(在 Hadoop Streaming 中生成单独的输出文件)
本文介绍了在 Hadoop Streaming 中生成单独的输出文件的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
只使用一个映射器(一个 Python 脚本)而不使用 reducer,我怎样才能为每一行输出输出一个以键作为文件名的单独文件,而不是输出长文件?
Using only a mapper (a Python script) and no reducer, how can I output a separate file with the key as the filename, for each line of output, rather than having long files of output?
推荐答案
您可以使用 python 文件函数写入本地文件系统上的文本文件,或者如果您想使用 HDFS,请使用 Thrift API.
You can either write to a text file on the local filesystem using python file functions or if you want to use HDFS use the Thrift API.
这篇关于在 Hadoop Streaming 中生成单独的输出文件的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
沃梦达教程
本文标题为:在 Hadoop Streaming 中生成单独的输出文件


基础教程推荐
猜你喜欢
- 线程时出现 msgbox 错误,GUI 块 2022-01-01
- Python kivy 入口点 inflateRest2 无法定位 libpng16-16.dll 2022-01-01
- 筛选NumPy数组 2022-01-01
- Dask.array.套用_沿_轴:由于额外的元素([1]),使用dask.array的每一行作为另一个函数的输入失败 2022-01-01
- 在 Python 中,如果我在一个“with"中返回.块,文件还会关闭吗? 2022-01-01
- 用于分类数据的跳跃记号标签 2022-01-01
- 使用PyInstaller后在Windows中打开可执行文件时出错 2022-01-01
- 如何让 python 脚本监听来自另一个脚本的输入 2022-01-01
- 如何在海运重新绘制中自定义标题和y标签 2022-01-01
- 何时使用 os.name、sys.platform 或 platform.system? 2022-01-01