hdfs java API

package com.hadoop.hdfs;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.BlockLocation;
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.hdfs.DistributedFileSystem;
import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
import org.apache.hadoop.io.IOUtils;

public class HdfsPractise {
public static void main(String[] args) throws IOException {
//makeDir();
//touchFile();
//uploadFromLocal();
//reName();
//delFile();
//searchBlock();
//getNodeInfo();
}

private static void makeDir() throws IOException {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://118.192.153.114:8020");
FileSystem fs = FileSystem.get(conf);
if(!fs.exists(new Path("/test4"))) {
fs.mkdirs(new Path("/test4"));
}
}
private static void touchFile() throws IOException {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://118.192.153.114:8020");
FileSystem fs = FileSystem.get(conf);
//fs.setReplication(new Path("/test1"), (short) 1);
FSDataOutputStream out = fs.create(new Path("/test2/sample_age_data.txt"));
FileInputStream in = new FileInputStream("d:\\sample_age_data.txt");
IOUtils.copyBytes(in, out, 1024, true);
}
private static void uploadFromLocal() throws IOException {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://118.192.153.114:8020");
FileSystem fs = FileSystem.get(conf);
fs.copyFromLocalFile(new Path("d:\\sample_age_data.txt"), new Path("/test2"));
}
private static void reName() throws IOException {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://118.192.153.114:8020");
FileSystem fs = FileSystem.get(conf);
fs.rename(new Path("/test2/sample_age_data.txt"), new Path("/test2/fff"));
}
private static void delFile() throws IOException {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://118.192.153.114:8020");
FileSystem fs = FileSystem.get(conf);
fs.delete(new Path("/test2"), true);
}
private static void searchBlock() throws IOException {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://118.192.153.114:8020");
FileSystem fs = FileSystem.get(conf);
FileStatus fst = fs.getFileStatus(new Path("/test1/aaa.txt"));
BlockLocation[] bls=fs.getFileBlockLocations(fst, 0, fst.getLen());
for (int i = 0,h=bls.length; i < h; i++) {
String[] hosts= bls[i].getHosts();
System.out.println("block_"+i+"_location:  "+hosts[0]);
}
}
private static void getNodeInfo() throws IOException {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://118.192.153.114:8020");

FileSystem fs = FileSystem.get(conf);
DistributedFileSystem hdfs = (DistributedFileSystem) fs;
DatanodeInfo[] dns=hdfs.getDataNodeStats();
for (int i = 0,h=dns.length; i < h; i++) {
System.out.println("datanode_"+i+"_name:  "+dns[i].getHostName());
}
}

}