草庐IT

utilProgressable

全部标签

java - 使用 org.apache.hadoop.utilProgressable 接口(interface)

有人可以提供一个示例,说明在调用FileSystem.create()时如何实现Progressable接口(interface)以供使用吗?我在另一篇文章中看到了以下代码片段,但它没有显示bytesWritten的来源:OutputStreamos=hdfs.create(file,newProgressable(){publicvoidprogress(){out.println("...byteswritten:["+bytesWritten+"]");}});这个接口(interface)的文档上说是为了向Hadoop框架报告进度,避免在长时间操作的情况下超时,但是《Hadoo