我正在開發Hive查詢使用R文件的作業,這些文件分佈在羣集上以便在每個節點上運行。 就像是: ADD FILES hdfs://path/reducers/my_script.R
SET hive.mapred.reduce.tasks.speculative.execution=false;
SET mapred.reduce.tasks = 80;
INSERT OVERWRITE T
public class PrimeMapper extends Mapper<LongWritable,IntWritable,IntWritable,NullWritable>
{
public void map(LongWritable k,IntWritable val,Context c) throws IOException, InterruptedExcepti