- 论坛徽章:
- 11
|
#!/bin/env python
import sys
if len(sys.argv)>=2:
clndr_dt_id=sys.argv[1]
else:
clndr_dt_id=''
if len(sys.argv)>=3:
ds=sys.argv[2]
else:
ds=''
sql="""
use edaa;
set mapreduce.job.queuename=datagather;
set mapred.child.java.opts=-Xmx1024m;
set hive.auto.convert.join.noconditionaltask = true;
set hive.auto.convert.join.noconditionaltask.size = 10000;
INSERT OVERWRITE TABLE A partition
(clndr_dt_id = '%(clndr_dt_id)s', ds = '%(ds)s')
select B.id,B.number,B.emil from B where clndr_dt_id = '%(clndr_dt_id)s' and ds = '%(ds)s';
exit;
""" % locals()
print sql
|
|