@@ -310,6 +310,8 @@ class StreamingIteration(Iteration): def __init__(self, prog, opts): Iteration.__init__(self, prog, opts) self.opts += configopts('streaming', prog, self.opts) + hadoop = getopt(self.opts, 'hadoop', delete=False)[0] + self.opts += configopts('streaming_' + hadoop, prog, self.opts) def run(self): retval = Iteration.run(self) dumbo/core.py 045d9d48310689b915311e19d6c14de1e5f168a0 klbostee klaas.bosteels@gmail.com http://github.com/klbostee/dumbo/commit/9b96aa0045196c61b6143b3ec7914100ad1f3778 9b96aa0045196c61b6143b3ec7914100ad1f3778 2009-04-23T11:34:49-07:00 2009-04-23T11:34:49-07:00 Closes #18 0c4b00e4b9a83ef18df47280e3390948a044f264 klbostee klaas.bosteels@gmail.com