只使用一个映射器(一个 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 中生成单独的输出文件的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持html5模板网!
python:不同包下同名的两个模块和类python: Two modules and classes with the same name under different packages(python:不同包下同名的两个模块和类)
配置 Python 以使用站点包的其他位置Configuring Python to use additional locations for site-packages(配置 Python 以使用站点包的其他位置)
如何在不重复导入顶级名称的情况下构造python包How to structure python packages without repeating top level name for import(如何在不重复导入顶级名称的情况下构造python包)
在 OpenShift 上安装 python 包Install python packages on OpenShift(在 OpenShift 上安装 python 包)
如何刷新 sys.path?How to refresh sys.path?(如何刷新 sys.path?)
分发带有已编译动态共享库的 Python 包Distribute a Python package with a compiled dynamic shared library(分发带有已编译动态共享库的 Python 包)