Thanks Olga. But what it running in mapreduce mode? Once the distributed cache 
is enable in this mode, there should still be some way to read these cached 
files. Actually, searching all the source files in pig-0.7, I can't find 
'DistributedCache.getLocalCacheFiles' anywhere and I soppose there is no other 
way to read cached files. This is what confuse me. Any other ideas?

-Gang




----- 原始邮件 ----
发件人: Olga Natkovich <ol...@yahoo-inc.com>
收件人: pig-dev@hadoop.apache.org
发送日期: 2010/6/7 (周一) 6:50:01 下午
主   题: RE: distributed cache in pig

This is because Hadoop 20 does not support distributed cache in local
mode. My understanding is that it would be part of Hadoop 22.

Olga

-----Original Message-----
From: Gang Luo [mailto:lgpub...@yahoo.com.cn] 
Sent: Monday, June 07, 2010 3:40 PM
To: pig-dev@hadoop.apache.org
Subject: distributed cache in pig

HI all,
I notice that whether pig use distributed cache depends on the context
(local or mapreduce). When running in mapreduce mode, the distributed
cache is always enable (e.g. replicated join). However, I never find
such method, DistributedCache.getLocalCacheFiles(job), which get the
cached file from the local disk. So, how does pig read these files from
local disk? I am looking at the pig 0.7 source code.

Thanks,
-Gang



Reply via email to