-
Notifications
You must be signed in to change notification settings - Fork 1
Questions
The input_ops parameter specifies a list of operator identifiers that provide input tuples for the current operator or paths to files from which the operator should read its input tuples.
Como é que é suposto fazer o "escalonamento" dos vários tuplos disponíveis nos vários inputs? Por exemplo, considerando que o OP atual tem inputs OP1, file1 e OP2, é suposto:
- ver se OP1 tem coisas, ler o file1 todo e depois ler do OP2?
- ler um tuplo alternadamente de cada input?
- ...
A ordem não interessa. Podemos, por exemplo, ler do ficheiro quando não houver input dos OPs.
Quando um PCS inicia um OP, este precisa de saber várias coisas acerca da sua configuração, nomeadamente:
- porta
- routing policy
- operação a realizar
- ...
Como é que o OP recebe estas configurações?
- argumentos do executável? (parece-me complicado)
- PCS chama método init e envia configurações depois de iniciar o processo do OP? (seems do-able)
- ficheiro de configuração está disponível em todas as máquinas? (mais fácil)
- ...
O PCS precisa de receber as configurações do Master, certo?
Não perguntei directamente ao prof, mas pelo que averiguei ambas as formas servem (em que apenas o PuppetMaster tem o ficheiro).