HandWritingRecognition/Upload.java at master · sc543753481/HandWritingRecognition · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
package com.briup.knn;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocalFileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;

public class Upload extends Configured implements Tool{
	public static void main(String[] args) throws Exception {
		ToolRunner.run(new Upload(), args);
	}

	//上传
	@Override
	public int run(String[] arg0) throws Exception {
		// TODO 自动生成的方法存根

		Configuration conf=getConf();
		FileSystem fs=FileSystem.get(conf);
		//获得程序到hfds的输出流
		FSDataOutputStream out = fs.create(new Path(conf.get("outpath")));
		//------------------------------------------------
		LocalFileSystem localfs = FileSystem.getLocal(conf);
		FSDataInputStream in = localfs.open(new Path(conf.get("inpath")));
		IOUtils.copyBytes(in, out, 128, true);

		return 0;
	}
}