我知道可以使用以下方法将可写对象传递给mapper:
defaultstringifier.store(conf,object,“key”);
object=defaultstringifier.load(conf,“key”,class);
我的问题是:
在一个Map器中,我读出对象,然后改变这个对象的值,
例如:object=another。
如何确保对象值的变化
在下一次Map绘制任务时可以知道吗?
有没有更好的方法将参数传递给Map器?
我知道可以使用以下方法将可写对象传递给mapper:
defaultstringifier.store(conf,object,“key”);
object=defaultstringifier.load(conf,“key”,class);
我的问题是:
在一个Map器中,我读出对象,然后改变这个对象的值,
例如:object=another。
如何确保对象值的变化
在下一次Map绘制任务时可以知道吗?
有没有更好的方法将参数传递给Map器?
1条答案
按热度按时间2cmtqfgy1#
改用文件系统。在hdfs中写入值,并用不同的内容替换该文件。config和distributedcache都不适合可变状态。