Class: Job

.mapreduce. Job


new Job(controllerId, split, map, reduce, clusterNode [, opt_includes])

Estrutura que encapsula a execução de uma tarefa associada a um MapReduce.
Importante:Esta classe não deve ser acessada diretamente. O MapReduce a utiliza internamente.

Parameters:
Name Type Argument Description
controllerId string

Id do MapReduce associado a este job.

split Array

Bloco de dados que será processado.

map function

Função de mapeamento. Esta função será chamada para cada valor contido em split através deste Job. Esta função deve definir chaves e valores através do método emit, disponível em seu contexto. Este método recebe como primeiro parâmetro uma string que representará a chave e no segundo parâmetro o valor que fará parte do conjunto de valores relacionados à chave definida no primeiro parâmetro. A função emit pode ser chamada mais de uma vez dentro de um map. Exemplo:
function (value) {
if (value % 2 === 0) {
this.emit('pares', value);
} else {
this.emit('impares', value);
this.emit('imparesDobrados', value * 2);
}
}

reduce function

Função de redução. Recebe dois parâmetros. Uma chave e um vetor de valores associados a ela.

clusterNode Object

Engine que irá executar este Job.

opt_includes Array.<string> <optional>

Endereços das bibliotecas que devem ser inclusas na execução dos testes.

Members


<static> STATUSES :string

Conjunto de estados que um uwl.mapreduce.Job pode assumir no decorrer do processamento de um mapreduce.

Type:
  • string
Properties:
Name Type Default Description
STOPPED string stopped
STARTED string started
DONE string done
ERROR string error
OFFLINE string offline
RUNNING string running
FAILED string failed

clusterNode :Object

Engine executor.

Type:
  • Object

conn_ :Connection

Conexão com o nó.

Type:

data :*

Dados transmitidos pelo nó.

Type:
  • *

id :string

Índice de identificação do job.

Type:
  • string

message :string

Caso tenha ocorrido algum erro no momento do processamento dos dados no nó, a mensagem de erro será guardada neste atributo.

Type:
  • string

split :Array

Bloco de dados que serão processados.

Type:
  • Array

status :string

Estado da tarefa.

Type:
  • string

taskId :string

Tarefa do schedule.

Type:
  • string

Methods


trigger()

Inicia tarefa no engine remoto.

Returns:

Status e os dados vinculados a ele.

Type
Object

update()

Checa o nó e atualiza o #status.