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 135:
}
}
</syntaxhighlight>
public void reduce(IntWritable moeda, Iterator<DoubleArrayWritable> lancamentos, OutputCollector<IntWritable, DoubleWritable>output, Reporter reporter){
double numero_caras = 0;
double numero_coroas = 0;
while(jogadas.hasNext()){
DoubleWritable[] lancamento = (DoubleWritable[]) lancamentos.next().get();
numero_caras += lancamento[HEADS].get();
numero_coroas += lancamento[TAILS].get();
}
try{
Double probabilidade_cara = numero_caras/(numero_caras+numero_coroas);
output.collect(moeda, new DoubleWritable(probabilidade_cara));
}catch(Exception e){
System.out.println("erro no reduce");
}
}
<syntaxhighlight lang="Java">
 
</syntaxhighlight>