如何在mapreduce中从reducer输出中删除r-00000扩展
在MapReduce中，r-00000扩展是Reducer任务的输出文件的一部分。要从reducer输出中删除r-00000扩展，可以按照以下步骤进行操作：
- 确定Reducer任务的输出目录：在MapReduce作业中，Reducer任务的输出通常存储在指定的输出目录中。首先，需要确定这个输出目录的位置。
- 进入Reducer输出目录：使用命令行或文件浏览器进入Reducer任务的输出目录。
- 查找r-00000文件：在Reducer输出目录中，查找以r-00000为扩展名的文件。这是Reducer任务输出的主文件。
- 删除r-00000文件：删除r-00000文件，可以使用命令行或文件浏览器的删除操作。确保在删除之前备份重要数据。
- 验证删除结果：删除r-00000文件后，可以验证Reducer输出目录中是否不再包含该文件。
需要注意的是，删除r-00000文件可能会导致MapReduce作业的结果不完整或不正确。在执行此操作之前，请确保了解MapReduce作业的整体流程和需求，并评估删除r-00000文件对结果的影响。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云MapReduce产品介绍：https://cloud.tencent.com/product/emr
- 腾讯云对象存储COS：https://cloud.tencent.com/product/cos
- 腾讯云云服务器CVM：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库CDB：https://cloud.tencent.com/product/cdb
- 腾讯云人工智能AI：https://cloud.tencent.com/product/ai
相关·内容
我编写了一个MapReduce程序(mapper.py和reducer.py)来处理Hadoop中的PageRank问题。
我想迭代MapReduce大约10个迭代。如何将第一轮MapReduce的输出转换为第二轮MapReduce的输入？
1 2 10
[mapper->reducer] -> [mapper->reducer] -> ... -> [mapper->reducer] -> final result
浏览 1提问于2017-04-13得票数 0
回答已采纳
我正在使用Hadoop 0.20，我希望有两个reduce输出文件，而不是一个输出文件。我知道MultipleOutputFormat不能在Hadoop0.20中工作。我将hadoop1.1.1-core jar文件添加到Eclipse中我的项目的构建路径中。但它仍然显示最后一个错误。
下面是我的代码：
public static class ReduceStage extends Reducer<IntWritable, BitSetWritable, IntWritable, Text>
{
private MultipleOutputs mos;
public
浏览 10提问于2013-09-25得票数 1
1回答
映射减少程序，该程序以两个文件作为输入，并给出两个文件(两个文件的交集)中的一组单词。
我试过这样..。
映射函数:以文件为输入，给出(word，1)作为输出。我在一个名为-r-00000的文件中得到了这个输出.我对这两个文件做了这个步骤，现在我有了两个文件(两个部分-r-00000文件)。
如何将这些文件作为输入来减少功能。
并对编写两个文件交集的约简函数给出了一些建议。
这是单词计数示例程序：
package org.apache.hadoop.examples;
import java.io.IOException;
import java.util.StringTokeniz
浏览 4提问于2013-11-18得票数 1
我正在尝试一个简单的示例，其中一个MapReduce作业的输出应该是另一个MapReduce作业的输入。
流程应该是这样的：Mapper1 --> Reducer1 --> Mapper2 --> Reducer2 ( Mapper1的输出必须是Reducer1的输入。Reducer1的输出必须是Mapper2的输入。Mapper2的输出必须是Reducer2的输入。Reducer2的输出必须存储在输出文件中)。
如何将多个Mapper和Reducer添加到我的程序中，以便像上面那样维护流程？
我需要使用链映射器还是减链器？如果是这样，我该如何使用它们？
浏览 2提问于2015-06-16得票数 2
我对从Mapper获得的输出感到有点困惑。
例如，当我使用以下输入文本运行一个简单的wordcount程序时：
hello world
Hadoop programming
mapreduce wordcount
lets see if this works
12345678
hello world
mapreduce wordcount
这是我得到的输出：
12345678 1
Hadoop 1
hello 1
hello 1
if 1
lets 1
mapreduce 1
mapreduce 1
programming 1
see 1
this 1
w
浏览 1提问于2014-07-16得票数 6
回答已采纳
1回答
现在，我正在编写一个Java程序，以便使用Hadoop HBase将输出写入MapReduce。问题是关于Combiner类。因为现在我的还原类扩展了TableReducer，而不是Reducer。那么，我的组合器类呢，它也是扩展TableReducer，还是仍然扩展Reducer？
浏览 0提问于2013-09-05得票数 1
回答已采纳
我希望能够从相同的reducer输出中写入多个目录。我正在使用MultipleOutput来写入多个文件。现在，我想将这些文件移动到不同的目录。如何在Java的Hadoop MapReduce程序中做到这一点？
浏览 1提问于2014-04-08得票数 1
1回答
我正在使用Python元组，并且有一个文本文件，如下所示
(1,value1)
(2,value2)
(3,value3)
...
(100,value100)
如何将MapReduce作业配置为按元组中的第一个键作为整数进行排序？
我的reduce作业需要输出一个有序的元组列表，所以我不想开始用制表符替换括号和逗号。这将是一个痛苦的转换回元组。
我使用以下参数从bash运行我的hadoop作业：
hadoop jar /usr/local/Cellar/hadoop/2.*/libexec/share/hadoop/tools/lib/hadoop-streaming-2*.jar
-D
浏览 0提问于2016-05-02得票数 0
1回答
此代码对单词进行计数，并跳过两个给定的单词(in& of)，形成一个文件：-请帮助它为什么不跳过这些单词。
import java.io.IOException;
import java.util.StringTokenizer;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.LongWritable;
import org.apache.
浏览 2提问于2016-01-20得票数 1
回答已采纳
2回答
使用mapreduce作业，我正在尝试从Hbase表中删除行。
我得到了以下错误。
java.lang.ClassCastException: org.apache.hadoop.hbase.client.Delete cannot be cast to org.apache.hadoop.hbase.KeyValue
at org.apache.hadoop.hbase.mapreduce.HFileOutputFormat$1.write(HFileOutputFormat.java:124)
at org.apache.hadoop.mapred.Redu
浏览 2提问于2014-04-24得票数 3
1回答
我正在与亚马逊的MapReduce网络服务的一个大学项目。为了将数据用于MapReduce，我需要将它们从关系数据库(AWS RDS)转储到S3中。在MapReduce完成后，我需要拆分输出文件并将其中的一大块加载到它们自己的S3存储桶中。
在Amazon Web服务环境中执行此操作的好方法是什么？
最好的情况:除了用于RDS和MapReduce的实例之外，是否可以在不使用额外的EC2实例的情况下实现这一点？
我将python用于映射器和reducer函数，并将json说明符用于MapReduce作业流。否则，我不会受到语言或技术的限制。
浏览 2提问于2011-01-12得票数 0
回答已采纳
我想使用hadoop流方法在中运行python映射减少作业。我的地图减少python脚本、输入文件和作业结果输出都位于中。
我试着运行这个命令
hadoop jar /usr/lib/hadoop-mapreduce/hadoop-streaming.jar -file gs://bucket-name/intro_to_mapreduce/mapper_prod_cat.py -mapper gs://bucket-name/intro_to_mapreduce/mapper_prod_cat.py -file gs://bucket-name/intro_to_mapreduce/redu
浏览 1提问于2017-12-28得票数 2
回答已采纳
有人能为mapreduce和Hbase提供一个很好的例子链接吗？我的要求是在hdfs文件上运行mapreduce，并将reducer输出存储到hbase表中。映射器的输入将是hdfs文件，输出将是文本、IntWritable键值对。Reducers的输出将被放入object，即添加reducer迭代的hbase值并存储在IntWritable表中。
浏览 1提问于2012-11-27得票数 1
回答已采纳
我试图做家庭作业，从数据操作的比例:系统和算法在Curesra与python有关。通常，我在理解基本代码方面存在问题，这是作为MapReduce alogorythm的一个例子。我希望能在以下两个地方帮助我理解它。
我厌倦了在运行命令之后一步一步地遍历下面两个文件的代码流：
python wordcount.py 'data/books.json'
打开文件wordcount.py
创建了mr = MapReduce.MapReduce() - me对象。
执行来自def __init__(self):的MapReduce.py部件
我们回到wordcount.
浏览 2提问于2015-12-11得票数 0
回答已采纳
1回答
我希望我的python程序输出前十个最常用单词的列表及其相关的单词计数。我必须使用mrjob - mapreduce来创建这个程序。我写了一个程序，找出单词的频率，并按从大到小的顺序输出它们。然而，我不确定如何只输出最常用的前十个单词。我在想，也许我可以把它放在一个列表中，并使用第二个map reducer进行排序，但我不确定如何使用mapreduce来做到这一点。我用mapreduce和python进行了新的编程。有人能给我一些建议吗？
from mrjob.job import MRJob
from mrjob.step import MRStep
import re
# Word
浏览 0提问于2017-10-24得票数 0
要创建MapReduce作业，您可以使用旧的org.apache.hadoop.mapred包或用于Mapper和Reducer的较新的org.apache.hadoop.mapreduce包，作业...第一个被标记为已弃用，但同时这个被恢复了。现在我想知道是使用旧的mapred包还是使用新的mapreduce包来创建作业更好，以及为什么。或者它仅仅取决于您是否需要像MultipleTextOutputFormat这样的东西，而这些东西只在旧的mapred包中可用？
浏览 0提问于2011-09-29得票数 46
回答已采纳
我必须实现两个mapReduce作业，Mapper_2需要Reducer_1的输出。Mapper_2还需要另一个输入，即文本文件。如何使用这两个输入来设计mapper_2？换句话说，如何在mapper_2中定义两个输入参数作为mapreduce中前一个作业的输出和一个文本文件？
浏览 1提问于2013-09-11得票数 1
1回答
我有一个文本文件：
10 1 15
10 12 30
10 9 45
10 8 40
10 15 55
12 9 0
12 7 18
12 10 1
9 1 1
9 2 1
9 0 1
14 5 5
我想将这个文件作为我的MapReduce作业的输出：
9 0 1
9 1 1
9 2 1
10 1 15
10 9 40
10 9 45
10 12 30
10 15 55
12 7 18
12 9 0
12 10
浏览 22提问于2018-01-25得票数 1
3回答
我正在运行亚马逊运行弹性MapReduce的示例，并经常遇到以下错误：
启动作业时出错，输出路径已经存在。
下面是运行我正在使用的作业的命令：
C:\ruby\elastic-mapreduce-cli>ruby elastic-mapreduce --create --stream \
--mapper s3://elasticmapreduce/samples/wordcount/wordSplitter.py \
--input s3://elasticmapreduce/samples/wordcount/input \
--outpu
浏览 11提问于2012-07-29得票数 2
回答已采纳
我有一个mapreduce程序，它首先扫描HBase表。
我想要一些reducer输出到hdfs，一些reducer输出写入hbase表。可以将reducer配置为输出到两个不同的位置/格式吗？
浏览 2提问于2012-03-15得票数 2
回答已采纳
我正在尝试将reduce的输出发送到映射，通过链接管道，类似于这个人：我尝试了他的解决方案，但是没有效果。我的管道流程是：
Map1
Reduce1
Map2
Reduce2
我将Reduce1的输出保存到blob_key下的blobstore中，然后尝试从Map2访问blob。但是在执行第二个映射时，我得到了以下错误："BadReaderParamsError: Could not find blobinfo for key <blob_key here>"。
以下是管道代码：
class SongsPurchasedTogetherPipeline(base_h
浏览 3提问于2017-03-27得票数 0
如何在普通java项目中调用map reduce方法，是否可以将reducer输出返回为数组/哈希图而不是平面文件，以及如何从jboss appServer访问mapreduce方法。
浏览 0提问于2013-07-01得票数 0
如何编写一个MapReduce程序，其中我的映射器的输出到Reducers，而Reducers的输出到另一个Reducer，但在这种情况下，只有一个Reducer，所以所有输出的键值对都将到同一个Reducer。
浏览 0提问于2015-12-01得票数 1
我正在尝试执行python MapReduce wordcount程序。
我从获得它只是为了试图理解它是如何工作的，但问题总是工作不成功！
我使用这个库在mapper.py中执行Cloudera VM和reducer.py
/usr/lib/hadoop-0.20-mapreduce/contrib/streaming/hadoop-streaming-2.6.0-mr1-cdh5.12.0.jar
执行命令：
hadoop jar /usr/lib/hadoop-0.20-mapreduce/contrib/streaming/hadoop-streaming-2.6.0-mr1-cdh5.
浏览 4提问于2017-10-31得票数 0
回答已采纳
我正在尝试实现一个算法，其中只需要一个reducer，并且mapreduce作业是迭代执行的。在特定迭代中，每个映射器的结果将被添加到reducer中，然后进行处理。然后，在其他迭代中，将归约器的输出作为输入传递给映射器。我希望以异步方式执行作业，即一旦执行了预定义数量的映射器，就将输出直接传递给reducer，即避免打乱和排序，因为它只会给我的算法带来开销。这有可能吗？如果不是，那么在实现级别上如何处理mapreduce作业的异步执行。我查阅了许多研究论文，但都无法从中获得任何想法。
谢谢。
浏览 0提问于2016-12-22得票数 2
我正在学习来自的Hadoop MapReduce示例。
程序中的Context是否指
如果是，为什么它可以使用不合格的Context而不使用import org.apache.hadoop.mapreduce.Mapper.Context
谢谢。
import java.io.IOException;
import java.util.StringTokenizer;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWrit
浏览 1提问于2019-05-21得票数 0
回答已采纳
当我使用MRUnit运行基本MultipleOutputs时，会得到以下异常：
java.lang.NullPointerException
at org.apache.hadoop.fs.Path.<init>(Path.java:105)
at org.apache.hadoop.fs.Path.<init>(Path.java:94)
at org.apache.hadoop.mapreduce.lib.output.FileOutputFormat.getDefaultWorkFile(FileOutputFormat.java:264)
at org.apac
浏览 4提问于2015-04-30得票数 0
回答已采纳
我正在进行从mongodb到mysql的迁移。我在一个集合中有一个子文档，我需要使用子文档来查找数据。
集合结构如下所示
{
"_id" : ObjectId("578506a90420bec15ea33783"),
"reselected" : "ABCDEFGH",
"reskip" : [],
"restatus" : "active",
"reuser" :
浏览 15提问于2016-07-25得票数 2
Hadoop MapReduce中的组合器逻辑总是与Reducer逻辑相同吗？或者，是否存在组合器逻辑与Reducer逻辑不同的情况？
浏览 2提问于2015-11-23得票数 1
我有一个mapreduce函数，它的输出应该提供给另一个mapreduce函数，代码如下所示
function clustering = parallel_clustering_kmeans(data)
%% find first clustering from all chunks
result = mapreduce(data,@k_means_Mapper,@k_means_Reducer);
result = readall(result);
index = result{:,1};
index = cell2mat(cellfun(@str2num,strrep(index,'
浏览 1提问于2016-04-30得票数 0
回答已采纳
public void setup(Context context) throws IOException, InterruptedException{
Configuration conf = context.getConfiguration();
org.apache.hadoop.mapreduce.Cluster cluster = new org.apache.hadoop.mapreduce.Cluster(conf);
Job currentJob = cluster.getJob(context.getJo
浏览 3提问于2015-12-15得票数 1
到目前为止，我在Google App Engine中有三个MapReduce作业链接在一起。在每个MapReduce作业之间，我输出输出并将该输出传递给下一个MapReduce作业。现在，我想将两个不同的输出(每个来自不同的MapReduce作业)传递给一个MapReduce作业。有谁能建议如何做到这一点吗？我将在下面粘贴我的Pipeline：
num_shards=2
# First define the parent pipeline job
class RecommenderPipeline(base_handler.PipelineBase):
"""A pip
浏览 2提问于2014-06-16得票数 1
我能够编译驱动程序，Mapper和reducer程序而没有错误。我创建了jar文件，甚至检查了输入数据集。一切看起来都很好。下面是驱动程序、映射器和减速器。有没有人能看看我犯了什么愚蠢的错误。我创建了5个mapreduce java程序，它们都运行得很好。我上传了github。
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import
浏览 0提问于2016-06-16得票数 0
1回答
我只想验证我对这些参数及其关系的理解，如果我错了，请通知我。
mapreduce.reduce.shuffle.input.buffer.percent告诉分配给reducer的整个洗牌阶段的内存总量。
mapreduce.reduce.shuffle.memory.limit.percent告诉最大百分比的内存限制，一次洗牌可以消耗从mapreduce.reduce.shuffle.input.buffer.percent。
mapreduce.reduce.shuffle.merge.percent是启动内存中合并的使用阈值，表示为存储内存中映射输出而分配的总内存( mapre
浏览 11提问于2015-04-26得票数 4
回答已采纳
1回答
我想让我的hadoop流媒体工作。
但是我想使用第一步的输出作为我的mapreduce作业的第二步的输入，而不是存储在hdfs中，可能输出为stdout。有没有像linux管道这样的东西？如hadoop jar hadoop-streaming.jar -mapper map1.py -reducer reducer.py -input xx | hadoop jar hadoop-streaming.jar -mapper map2.py -reducer -input 2.py -output /output
浏览 3提问于2016-02-06得票数 1
3回答
MapReduce程序产生空输出
、、、、
我创建了一个mapreduce程序来获取World Indicator数据，以显示我想要分析的特定指标的结果。(即CO2排放)。在我的映射器中，我试图只保留我想要的数据(首先只保留具有特定指标的行)，然后保留国家和所有排放水平(在字符串数组中)。
我的整个程序都在运行，但我注意到它正在接收Map输入记录，但没有Map输出记录或Reduce输入/输出记录。
我一直试图找出我的逻辑哪里错了，但我被难住了。任何意见都是值得感谢的。
我的代码如下：
-Mapper--
package org.myorg;
import java.io.IOException;
import org.apache.
浏览 1提问于2014-09-30得票数 2
我正在尝试在Hadoop0.20.1中使用MultipleOutputFormat，它们似乎只适用于过时的'JobConf‘，而后者又使用过时的映射器和还原器(org.apache.hadoop.mapred.Reducer)等。有什么想法可以使用新的'org.apache.hadoop.mapreduce.Job‘来获得多个输出功能(或者至少命名reducer输出功能)？
浏览 0提问于2011-03-19得票数 0
回答已采纳
3回答
Hadoop输出到MongoDb
、、、、
我想编写Java程序，它从HDFS读取输入，使用MapReduce处理输入，并将输出写入MongoDb。
下面是一个场景：
我有一个Hadoop集群，它有3个数据节点。
java程序从HDFS读取输入，并使用MapReduce处理它。
最后，将结果写入MongoDb。
实际上，读取HDFS并使用MapReduce处理它很简单。但是，我不得不将结果写入MongoDb。是否支持Java将结果写入MongoDB？另一个问题是，由于它是Hadoop集群，所以我们不知道哪个datanode将运行Reducer任务并生成结果，是否可以将结果写入安装在特定服务器上的MongoDb中？
如
浏览 3提问于2013-10-21得票数 1
我试图在Coursera上通过课程任务，但是在一些单元测试中失败了，错误如下：
RES1_6描述:第一个工作应该有一个以上的减速器，或者根本不应该有它们。请在-D mapreduce.job.reduces中设置适当的号码。它可以是0或超过1。
但是，我在下面的脚本中使用了NUM_REDUCERS=4！
yarn jar /opt/cloudera/parcels/CDH/lib/hadoop-mapreduce/hadoop-streaming.jar \
-D mapreduce.job.name="somename" \
-D mapreduce.jo
浏览 6提问于2021-11-21得票数 2
1回答
我试着用几天的时间用Oozie开始了一份wordount(MapReduce)工作。正常情况下(CMD："hadoop *.jar mainClass输入输出“)作业启动一切正常。目前的oozie配置是：
/ApplicationDIR/lib/WordCount.jar
/ApplicationDIR/workflow.xml .xml
/文本-IN
/文字输出
workflow.xml
${jobTracker} ${nameNode} mapred.job.queue.name ${queueName} mapred.mapper.class Hadoo
浏览 2提问于2016-02-05得票数 0
1回答
我运行了一个map reduce程序来读取HDFS文件，如下所示：
hadoop jar /opt/mapr/hadoop/hadoop-0.20.2/contrib/streaming/hadoop-0.20.2-dev-streaming.jar -Dmapred.reduce.tasks=1000 -file $homedir/mapper.py -mapper $homedir/mapper.py -file $homedir/reducer.py -reducer $homedir/reducer.py -input /user/data/* -output /output/
浏览 0提问于2015-11-13得票数 1
我是Hadoop的新手！现在，我尝试在Hadoop2.2.0中使用MultipleOutputFormat，但似乎它们只使用不推荐的“JobConf”，而后者又使用了弃推荐的Mapper和Reducer (org.apache.hadoop.mapred.Reducer)等等。如何使用新的“org.apache.hadoop.mapreduce.Job”实现多个输出功能？
浏览 0提问于2013-11-26得票数 2
回答已采纳
4回答
我试着用mapreduce写一个简单的字数统计程序。我的mapreduce程序只将输出写入文件。但是我不希望我的输出被写在文件中。我想收集这些信息或输出(就像java集合一样)，以便在我的其他程序区域中使用。
例如，如果我在hive上提交任何查询，它将返回一个结果集对象，但在内部，我的查询将被转换为mapreduce程序，并在完成作业后返回结果集对象。与其他mapreduce程序不同，它不会将结果写入文件系统。
那么，我如何收集输出，或者如何在reducer或映射器中准备自己对象，并在java程序的其他区域收集该对象？我不希望该输出被写入文件中。
浏览 0提问于2014-04-02得票数 3
使用mapreduce模拟内部连接相对简单，只需在reducer中映射公共键和连接值即可完成工作。但是，当涉及到左外部连接时，当左表中有不存在于右表中的键时，就会面临组合填充右表的空白的问题。当映射到reducer中时，不匹配的键将被丢弃，那么如何从左表添加这些不匹配的键呢？
例如，假设我们有两个文件：
Left = {'matches': 1}
Right = {'matches': 2,
'matches_not': 3}
人们可能想要一个类似如下的输出：
Output: {'matches-matches'
浏览 0提问于2012-12-10得票数 0
回答已采纳
作为初学者，我试图实现一个自定义的输入格式程序。直到Mapper，它才能正常工作，但与我实现的Reducer不同，默认的还原器正在被调用( Mapper的相同输出被打印在文件部件-r-0000中)。
我检查了程序的签名。同时，正确地给出了这两个阶段的键值类。甚至给出了减速机任务的数目。
我找不到为什么减速机没有被执行。我也检查过其他线程，但没有运气。
驱动程序
package cif;
import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hado
浏览 0提问于2016-03-09得票数 0
我正在使用hadoop "2.0.0-cdh4.1.1“，并尝试在我的wordCount程序中使用LongSumReducer。
job.setReducerClass((new LongSumReducer<Text>()).getClass());
然而，有一个编译错误：
setReducerClass(java.lang.Class<? extends org.apache.hadoop.mapreduce.Reducer>) in
org.apache.hadoop.mapreduce.Job cannot be applied to (java.lan
浏览 1提问于2012-11-20得票数 1
回答已采纳
当我删除job.setSortComparatorClass(LongWritable.DecreasingComparator.class);时，我无法理解这个bug是什么
我得到了输出，但是当我尝试使用它时，我得到了这个异常。
I试图根据值从减速器中按递减顺序得到输出，因此我使用了setsortcomparator类，所以请帮助我
package topten.mostviewed.movies;
import java.io.IOException;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.i
浏览 0提问于2018-10-11得票数 1
我试图通过传递字符串值将两个值从映射器输出到缩减程序，但是当我在映射器中解析字符串时，我得到了一个越界错误。但是，我在Mapper中创建了字符串，所以我确定它有两个值，我做错了什么？如何将两个值从映射器传递到缩减程序？(最终，我需要将更多变量传递给reducer，但这会使问题变得更简单。) 这是错误： Error: java.lang.ArrayIndexOutOfBoundsException: 1
at TotalTime$TimeReducer.reduce(TotalTime.java:57)
at TotalTime$TimeReducer.reduce(Total
浏览 12提问于2020-12-16得票数 0
回答已采纳
1回答
这是埃博拉数据集的代码。在这里，reducer根本没有被调用。仅打印映射器输出。
驱动程序类：
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.*;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
import org.apache.hadoop.mapreduce.lib.
浏览 4提问于2014-10-24得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
