eclipse连接ndsf配置

• 解压eclipse插件压缩包&＃xff1a;eclipse-mars
• 将hadoop-eclipse-plugin-2.6.0.jar以下jar包放入eclipse安装目录下的plugins文件夹中
• 启动eclips,新建java项目
• 
• 出现如下界面
  
• 新建项目
  
• 项目名
  
• 连接ndsf成功,右键可以对服务器文件进行操作
  
• 修改用户名 Linux是root用户,而windows用户名字和Linux不同
  
• 将hdfs安装包下的指定jar包和lib包下的所有jar包拷贝到eclipse项目中
  将common包下的指定jar包和lib包下的所有jar包拷贝到eclipse项目中
  1
  
  2
  
• 新建项目
  
  
• 导包
  1
  
  2
  
  3
  
  4
  
  5 把刚才拷贝的jar包整理在一起方便使用
  
  6
  
• 创建BaiduYun.java,拷贝core-site.xml和hdfs-site.xml
  

package com.yunpan;import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;public class BaiduYun {private static Configuration conf;private static FileSystem fs ;public static void main(String[] args) throws IOException {conf &＃61; new Configuration();fs &＃61; FileSystem.get(conf);// 创建删除文件夹目录操作mk_deledir();// 上传文件到HDFS &＃61; 写流程
// uploadfiles();// 下载
// downloadfiles();// 详细信息
// filestatus();}private static void filestatus() throws IOException {Path path &＃61; new Path("/JC");FileStatus[] fileStatus &＃61; fs.listStatus(path);for (int i &＃61; 0; i // 上传的地方Path path &＃61; new Path("/JC/ww");// 源文件存放地方File files &＃61; new File("C:/Users/peixin/Desktop/Note.txt");
// 上传 流FSDataOutputStream out &＃61; fs.create(path);IOUtils.copyBytes(new FileInputStream(files),out, conf);System.out.println("上传成功");}private static void mk_deledir() throws IOException {
// 指定文件目录路径Path path &＃61; new Path("/JC") ;if(fs.exists(path)){fs.delete(path,true);System.out.println("文件存在 已删除");}fs.mkdirs(path);System.out.println("创建文件夹成功");}}