submitJob+parseExpr问题,可以参考以下例子:
def factor0000(){ return table(1..100 as id); } def factor0001(){ return table(101..200 as id); }
funlist=dict(STRING,ANY)
f=exec name from defs() where name like "factor%"
for (i in f){
funlist[i]=funcByName(i)
}
def run_factor(dd){
factor=0
for(i in 0..1){
// sql0="select * from factor0000()"
// sql1=strReplace(sql0,"factor0000","factor"+lpad(string(i),4,"0"))
// factor=parseExpr(sql1,dd).eval()
fname="factor"+lpad(string(i),4,"0")
factor=factor+makeCall(dd[fname]).eval()
}
return factor
}
jodid=submitJob("test000" , "test000" , run_factor{funlist})
getJobReturn(jodid,1)