草庐IT

MPI_Reduce

全部标签

java - 如何在不使用已弃用类的情况下编写 Hadoop map reduce 作业?

我知道这是我的强制症,但我无法忍受在我的代码中使用弃用的引用。也就是说,包括“权威指南”一书在内的Hadoop教程仅使用已弃用的JobConf类和mapred包中的类,这些类均已弃用。我在任何地方都找不到有关如何将现有MapReduce作业转换为使用新构造的任何文本。 最佳答案 我不久前与Cloudera人员进行了交谈,他们确认"new"功能不完整,并且如果不使用“已弃用”的包,就无法编写正式的Hadoop内容。 关于java-如何在不使用已弃用类的情况下编写Hadoopmapreduc

hadoop - 在 Eclipse Map/Reduce 位置中,New Hadoop 位置没有响应?

在eclipse中,我正在尝试添加新的hadoop位置。但是当我点击添加新的hadoop位置时,它没有响应。我为hadoop1.0.4构建了自己的插件。我的list如下所示,Bundle-ClassPath:classes/,lib/hadoop-core.jar,lib/commons-configuration-1.6.jar,lib/commons-httpclient-3.0.1.jar,lib/commons-cli-1.2.jar,lib/commons-lang-2.4.jar,lib/jackson-mapper-asl-1.8.8.jar,lib/jackson-co

apache - Hadoop:map reduce 作业中的错误类路径

我在3个虚拟机中运行一个cloudera集群,并尝试通过mapreduce作业执行hbase批量加载。但我总是得到错误:error:Classorg.apache.hadoop.hbase.mapreduce.HFileOutputFormatnotfound所以,似乎map进程没有找到类。所以我尝试了这个:1)将hbase.jar添加到每个节点上的HADOOP_CLASSPATH2)将TableMapReduceUtil.addDependencyJars(job)/TableMapReduceUtil.addDependencyJars(myConf,HFileOutputForm

java - 如何使用配置文件中的输入参数执行 Map Reduce 作业

关闭。这个问题不符合StackOverflowguidelines.它目前不接受答案。要求提供代码的问题必须表现出对所解决问题的最低限度理解。包括尝试过的解决方案、为什么它们不起作用,以及预期结果。另请参阅:StackOverflowquestionchecklist关闭9年前。Improvethisquestion我想执行一个MR作业,我想通过配置文件将参数传递给作业。映射器和缩减器中也应使用相同的参数。哪个API最适合实现此目的?

java - 使用 Hadoop Map-Reduce 去除不可打印的字符

我正在尝试处理具有不可打印字符的HDFS文件。我希望使用MapReduce去除这些字符。我曾尝试使用PigTextLoader和MRTextInputFormat(在MR程序中),结果是从遇到不可打印字符的位置将记录拆分为多个。以下是示例数据:===数据==(2条记录)=4614:2011-12-20-08.45.08.169176^2011-12-20-18.15.08.100008^597^0^57^ZUKA^Grase^^^Grase,Dr^^^N^N^N^Dr^KG^ONLYINFORMATIONENTERED^UNKNOWN^0^^^^611190362�^0^^^^^^

apache - 我的 Yarn Map-Reduce 作业花费了大量时间

输入文件大小:75GB映射器数量:2273reducer数量:1(如网页界面所示)分割数:2273输入文件数:867集群:ApacheHadoop2.4.05个节点集群,每个1TB。1个主节点和4个数据节点。已经4小时了。现在仍然只完成了12%的map。只是想知道我的集群配置是否有意义,或者配置有什么问题吗?Yarn-site.xmlyarn.nodemanager.aux-servicesmapreduce_shuffleyarn.nodemanager.aux-services.mapreduce.shuffle.classorg.apache.hadoop.mapred.Shuf

algorithm - 使用 Map Reduce 的深度优先搜索

我已经在HadoopMapReduce(BreathFirstSearch)中成功实现了最短路径算法。但是我有一个问题:是否可以使用Hadoopmapreduce进行图形遍历“深度优先搜索”?任何链接..? 最佳答案 深度优先搜索的性质使其不适用于mapreduce作业。因为在进入另一条路径之前,您只遵循一条严格的路径。这导致您无法正确使用hadoop提供的可伸缩性。我不知道有什么好的工作实现,而且我很确定您不会找到一个以良好方式使用MapReduce范例的实现。如果您尝试自己在hadoop中实现图形算法,您可能想看看一些有用的框架

斯卡拉 MapReduce : [error] method reduce overrides nothing

我遇到了这个错误,我这样写了我的TableReducer代码:classtreducerextendsTableReducer[Text,IntWritable,ImmutableBytesWritable]{overridedefreduce(key:Text,values:java.lang.Iterable[IntWritable],context:Reducer[Text,IntWritable,ImmutableBytesWritable,Mutation]#Context){vari=0for(v通过这次导入:importorg.apache.hadoop.hbase.HB

eclipse - "Not A Valid Jar"尝试运行 Map Reduce 作业时

我试图通过从eclipse构建一个jar来运行我的MapReduce作业,但是在尝试执行该作业时,我收到“不是有效的Jar”错误。我尝试点击链接NotavalidJar但这没有帮助。任何人都可以给我有关如何从eclipse构建jar以使其在Hadoop上运行的说明。我知道从eclipse构建Jar文件的过程,但是我不确定,我是否需要特别注意构建jar文件,以便它在Hadoop上运行。 最佳答案 当您提交命令时,请确保您有以下内容来执行命令:当您指示jar时,请确保您正确指向jar。使用绝对路径可能最容易确定。要获取绝对路径,如果您导

java - map reduce 有两个输入文件,一个文件基于另一个文件处理

我需要编写一个将输入作为两个输入文件的mapreduce。第一个输入文件如下所示:key1,25key1,35key1,60key2,30key3,45key3,65第二个输入文件如下:key1,-10key2,-20key3,-15我需要得到如下输出:key1,15key1,25key1,50key2,10key3,30key3,50(输出是第一个输入文件的值减去第二个输入文件的值)这怎么可能?mapper和reducer任务会是什么样子?我的做法如下:我想我必须有两个映射器,每个输入文件一个(一个映射器可以用来读取两个文件吗?)。映射器将简单地发出键和值。在reducer端,当我收