|
其中一段简单的编码；
其中搭建Hadoop环境要比现在这段代码要复杂得多了。
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package com.xiva.baseKnowledge;
import java.io.IOException;
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
/**
*
* @author Xiva
*/
public class HadoopMain {
public static void createFloder(){
String uri = "hdfs://localhost:8889/xiva";//args[0];
Configuration conf = new Configuration();
//
//conf.set("hadoop.job.ugi", "xiva, 123");
//
FileSystem fs = null;
try {
Path path = new Path(uri);
fs = FileSystem.get(URI.create(uri), conf);
//fs.delete(path, true);
fs.mkdirs(path);
} catch (IOException e) {
// TODO Auto-generated catch block
} finally {
IOUtils.closeStream(fs);
}
}
public static void main(String[] args) {
// String queryString = " WHERE e.value.\"passtime\" <= $1";
// String q = queryString.replaceFirst("\\$1","2012-04-25");
// System.out.println(q);
}
}
放下好久了，希望以后还有研究的机会。 | 
转播
