我在试密码-
from org.apache.pig.scripting import *
P= Pig.compile("""
load_job_data= LOAD 'ics_job_detail_analytics_2016' using org.apache.hive.hcatalog.pig.HCatLoader();
job_detail_out= LIMIT load_job_data 2;
store job_detail_out into '$job_detail' using PigStorage(',');
""")
for i in range(1):
params= {}
job_detail= "job_detail_out"
params["job_detail"]= job_detail
Pig.fs("rmr " +job_detail)
bound= P.bind(params)
stats= bound.runSingle()
print(type(stats))
if not stats.isSuccessful():
raise 'failed'
print(type(stats.result("job_detail_out")))
#itr= stats.result("job_detail_out").iterator()
#while itr.hasNext():
# print(itr.next())
它总是给我'nonetype',因此我不能遍历输出。有什么帮助吗?下面是输出的最后几行-
2016-05-23 22:27:10,977 [main] INFO org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher - Success!
<type 'org.apache.pig.tools.pigstats.SimplePigStats'>
2016-05-23 22:27:10,985 [main] WARN org.apache.pig.tools.pigstats.SimplePigStats - Output alias isn't avalable for hdfs://psvlxihpnn1.informatica.com:8020/user/gcs_dev/job_detail_out
<type 'NoneType'>
暂无答案!
目前还没有任何答案,快来回答吧!