我使用hadoop来编写我搜集的数据。
我有一个spring服务,它从多个线程调用,将一些内容写入hdfs。
@Service
public class WriteService
{
public void write(String path, String content)
{
FileSystem fs = FileSystem.get(conf);
}
}
我不确定filesystem对象是否可以是writeservice的成员,也不确定它是否是线程安全的。我正在使用distributedfilesystem对象。
你知道它是否线程安全,我可以使用它作为我的服务的一个成员吗?
谢谢您
1条答案
按热度按时间dy2hfwbg1#
hadoop dfs使用所谓的蠕虫模型。这使得它在并发问题上更加健壮。
但是,要回答这个问题,它一般不安全。您仍然需要考虑并发控制需求。