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 111:
private double bias_2;
//capturarecupera o valor dos biasesdas probabilidadescalculadoscalculadas para cada moeda
public void configure(JobConf job){
bias_1probabilidade_1 = Double.parseDouble(job.get("bias_1probabilidade_1"));
bias_2probabilidade_2 = Double.parseDouble(job.get("bias_2probabilidade_2"));
}
public void map(LongWritable key, Text valuelinha, OutputCollector<IntWritable, DoubleArrayWritable> output){
String line = value.toString();
double[] headBiasescaraProbabilidades = new double[2];
headBiasescaraProbabilidades[0] = bias_1;
headBiasescaraProbabilidades[1] = bias_2;
DoubleArrayWritable[][] verossimilhancas = gera_verossimilhancas(line)
StringTokenizer tokenizer = new StringTokenizer(line);
int num_caras = Integer.parseInt(tokenizer.nextToken());
int num_coroas = Integer.parseInt(tokenizer.nextToken());
TossesSet tossesSet = new TossesSet(num_caras, num_coroas);
double[][] completion = tossesSet.getCompletion(headBiases);
DoubleWritable[] moeda1 = new DoubleWritable[2];
DoubleWritable[] moeda2 = new DoubleWritable[2];
moeda1[HEADS] = new DoubleWritable(completion[0][HEADS]);
moeda2[HEADS] = new DoubleWritable(completion[1][HEADS]);
moeda1[TAILS] = new DoubleWritable(completion[0][TAILS]);
moeda2[TAILS] = new DoubleWritable(completion[1][TAILS]);
try{
output.collect(new IntWritable(1), new DoubleArrayWritable(moeda1)verossimilhancas[0]);
output.collect(new IntWritable(2), new DoubleArrayWritable(moeda2)verrossimilhancas[1]);
}catch(Exception e){
System.out.println("erro");