读取HDFS上的文件问题

在伪分布模式下测试代码,在eclipse里建了个项目,然后在map函数里我想从hdfs中读取文件数据(testData.csv),然后这几段代码就会出现问题,String str_url="hdfs://localhost:9000";URI.creat(str_url);String str="hdfs://localhost:9000/user/input/testData.csv";Path path=new Path(str);
我发现如果是str="/user/input/testData.csv";Path=new Path(str);就不会出现问题,但是这个路径是不存在的。
因为有两个文件需要读取,不知道怎么处理啊~~~

1个回答

import org.apache.hadoop.fs.FileSystem;

这个包 有两种方式 调用

    FileSystem.get(arg0, arg1);
    FileSystem.get(conf);



    String uri = "hdfs://bigdata/tmp/1.txt";

    Configuration conf = new Configuration();

    FileSystem fs = FileSystem.get(URI.create(uri), conf);  

    或者

    FileSystem fs = FileSystem.get(conf);

    欢迎加入 hadoop 基础培训: http://blog.csdn.net/biperler/article/details/44731489
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问