Namespace: mapreduce

mapreduce

Classes

Job
JobConf
MapReduce

Methods


<static> execute(jobId, map, reduce, split)

Executa a função map para cada dado contido em split e reduz os resultados emitidos.

Parameters:
Name Type Description
jobId number

Identificador da operação de mapreduce.

map function

Função de transformação dos dados contidos em split.

reduce function

Função que reduz os valores emitidos pela função map para uma determinada key.

split Array

Bloco de dados que será processado.


<static> getExecutorOutputFileName(jobId)

Gera um nome do arquivo de saída para o executor.

Parameters:
Name Type Description
jobId string

Id do uwl.mapreduce.Job ligado ao executor.

Returns:

Nome do arquivo de saída.

Type
string

<static> getStatus(mapReduceId)

Retorna o estado da operação de MapReduce.

Parameters:
Name Type Description
mapReduceId number

Id do uwl.mapreduce.MapReduce.

Returns:
Type
Object

<static> runReduce_(mappedEntry, reduce)

Executa a redução em cima do resultado do mapeamento.

Parameters:
Name Type Description
mappedEntry Object.<string, *>

Dado já mapeado.

reduce function

Função de redução.

Returns:

Dado reduzido.

Type
Object.<string, *>