Processamento de Dados Massivos/Projeto e implementação de aplicações Big Data/Classificação associativa incremental (LAC): diferenças entre revisões
| [edição não verificada] | [edição não verificada] |
Conteúdo apagado Conteúdo adicionado
Linha 74:
=== Map ===
Cada mapper recebe como entrada um arquivo de texto que contem as instancias de teste a serem processadas
<syntaxhighlight lang="Java">
<key>\t<instance>
<key>\t<instance>
.
.
.
<key>\t<instance>
</syntaxhighlight>
Sendo que dentro de um mesmo arquivo todas as instancias possuem a mesma chave, para cada linha a função de map realiza o processo de classificação e extrai os dados pertinentes, no nosso caso as estatísticas de uso da cache, e os escreve na saída da função onde serão processados pelas funções de reduce. A seguir apresentamos a função de Map:
<syntaxhighlight lang="Java">
public void map(Text key, Text value, Context context) throws IOException, InterruptedException {
String line = value.toString();
try
{
Result result = this.classifier.distributionForInstance(line.split(" "));
context.write(missesText, new IntWritable(result.getMisses()));
context.write(hitsText, new IntWritable(result.getHits()));
} catch (Exception e) {
e.printStackTrace();
}
}
}
</syntaxhighlight>
=== Reduce ===
| |||