我所理解的是
distributedcache.getcachefiles()处于分布式模式,distributedcache.getlocalcachefiles()处于伪分布式模式。
那么,我们可以在mapreduce代码中检查是以伪模式还是分布式模式运行吗
if(distributed)
DistributedCache.getCacheFiles()
else
DistributedCache.getLocalCacheFiles()
我们可以这样做吗?或者有更好的方法吗。
即使我们在相对模式下使用distributedcache.getcachefiles()和distributedcache.getlocalcachefiles(),distributedcache也可以同时获取HDF或本地数据。
暂无答案!
目前还没有任何答案,快来回答吧!