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.