我正在使用 hadoop 来编写我抓取的数据。
我有一个从多个线程调用的 spring 服务以将一些内容写入 HDFS。
@Service
public class WriteService
{
public void write(String path, String content)
{
FileSystem fs = FileSystem.get(conf);
}
}
我不确定 FileSystem 对象是否可以成为 WriteService 的成员,我不知道它是否是线程安全的。我正在使用 DistributedFileSystem 对象。
你知道它是否是线程安全的并且我可以将它用作我的服务的成员吗?
谢谢