nginstack Namespace: mapreduce

Namespace: mapreduce

mapreduce

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

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

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.

Name	Type	Description
`jobId`	string	Id do uwl.mapreduce.Job ligado ao executor.

Nome do arquivo de saída.

<static> getStatus(mapReduceId)

Retorna o estado da operação de MapReduce.

Name	Type	Description
`mapReduceId`	number	Id do uwl.mapreduce.MapReduce.

<static> runReduce_(mappedEntry, reduce)

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

Name	Type	Description
`mappedEntry`	Object.<string, *>	Dado já mapeado.
`reduce`	function	Função de redução.

Dado reduzido.