Diferenças entre edições de "Processamento de Dados Massivos/Projeto e implementação de aplicações Big Data/Classificação associativa incremental (LAC)"

=== Map ===
 
Cada mapper recebe como entrada um arquivo de texto que contem as instancias de teste a serem processadas,. cadaO linhaformato do arquivo temde oentrada formatoé: "<key>\t<instancia>", onde a chave é o id do cluster que a instancia pertence, todas as instancias do arquivo possuem a mesma chave.
 
<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 ===