nginstack

Class: MapReduce

.mapreduce. MapReduce

new MapReduce(jobConf)

Controla a execução do MapReduce, criando e atribuindo subtarefas e observando os nós.

Parameters:
Name Type Description
jobConf uwl.mapreduce.JobConf

Tarefa de mapreduce que deverá ser executada.

Members

id :number

Índice de identificação do controller.

Type:
  • number

logger_ :Logger

Logger.

Type:

result :Object

Resultado da execução do MapReduce.

Type:
  • Object

Methods

<static> getOutputFileName(id)

Monta o nome do arquivo de output de um MapReduce.

Parameters:
Name Type Description
id string

Identificação deste job.
Returns:

Nome do arquivo.

Type
string

run()

Executa a tarefa.

Returns:

Resultado da execução.

Type
Object

saveOutput_(result, status, enginesRunning, completed, total)

Salva os dados do controlador em um arquivo.

Parameters:
Name Type Description
result Object

Resultado final ou parcial.
status string

Status atual do trabalho de MapReduce.
enginesRunning number

Quantos engines estão trabalhando.
completed number

Quantos splits foram concluídos.
total number

Quantos splits existem ao total.