java代码操作hdfs文件详解大数据

本文章主要介绍了java代码操作hdfs文件,具有不错的的参考价值,希望对您有所帮助,如解说有误或未考虑完全的地方,请您留言指出,谢谢!
import org.apache.hadoop.conf.Configuration; 
import org.apache.hadoop.fs.FileSystem; 
import org.apache.hadoop.fs.Path; 
 
import java.io.IOException; 
 
/** 
 * Created by zheng on 2020/4/9. 
 */ 
public class HdfsClient { 
    public static void main(String[] args) throws IOException { 
        Configuration configuration = new Configuration(); 
        configuration.set("fs.defaultFS","hdfs://localhost:9000"); 
 
        //获取文件系统 
        FileSystem fileSystem = FileSystem.get(configuration); 
 
        //拷贝本地test.log文件到hdfs 
        fileSystem.copyFromLocalFile(new Path("/Users/zheng/test.log"),new Path("/test.log")); 
 
        //关闭文件系统 
        fileSystem.close(); 
    } 
} 
#执行以下命令可看到文件已经成功拷贝 
$ hdfs dfs -ls / 
2020-04-09 16:01:39,201 WARN util.NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 
Found 1 items 
-rw-r--r--   3 zheng supergroup          0 2020-04-09 16:01 /test.log

原创文章,作者:506227337,如若转载,请注明出处:https://blog.ytso.com/228140.html

(0)
上一篇 2022年1月11日
下一篇 2022年1月11日

相关推荐

发表回复

登录后才能评论