Processamento de Dados Massivos/Projeto e implementação de aplicações Big Data/Maximização de expectativas: diferenças entre revisões
[edição não verificada] | [edição não verificada] |
Conteúdo apagado Conteúdo adicionado
Linha 106:
===Estratégias de Paralelização===
<syntaxhighlight lang="Java">
String line = value.toString();▼
private double bias_1;
private double bias_2;
//captura o valor dos biases já calculados para cada moeda
public void configure(JobConf job){
bias_1 = Double.parseDouble(job.get("bias_1"));
bias_2 = Double.parseDouble(job.get("bias_2"));
}
public void map(LongWritable key, Text value, OutputCollector<IntWritable, DoubleArrayWritable> output){
▲ try{
▲ output.collect(new IntWritable(2), new DoubleArrayWritable(moeda2));
▲ }catch(Exception e){
}
▲ System.out.println("erro");
</syntaxhighlight>
|