Classes
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, *>