From 645ee73e773eead042cad78fab8d15b4adea279d Mon Sep 17 00:00:00 2001 From: Klaas Bosteels Date: Wed, 26 Nov 2008 09:52:59 +0100 Subject: [PATCH] finished -namedcode --- src/python/dumbo.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/python/dumbo.py b/src/python/dumbo.py index 03f782d..b313c77 100644 --- a/src/python/dumbo.py +++ b/src/python/dumbo.py @@ -295,6 +295,8 @@ def startonstreaming(prog,opts,hadoop): "dumbo.code.writable.map.streamprocessor=%s" % opt[0])) opts.append(("mapper",dumbopkg + ".CodeWritablePipeMapper")) dumbojar_needed = True + if addedopts["namedcode"] and addedopts["namedcode"][0] == 'yes': + opts.append(("jobconf", "dumbo.as.named.code=true")) if dumbojar_needed: if not dumbojar: print >>sys.stderr,"ERROR: Dumbo jar not found"