日志

从通过Java API，用户身份验证的远程主机访问HDFS

已有 1074 次阅读2015-2-8 00:20 | Java

package org.myorg;

import java.security.PrivilegedExceptionAction;

import org.apache.hadoop.conf.*;

import org.apache.hadoop.security.UserGroupInformation;

import org.apache.hadoop.fs.Path;

import org.apache.hadoop.fs.FileSystem;

import org.apache.hadoop.fs.FileStatus;

public class HdfsTest {

public static void main(String args[]) {

try {

UserGroupInformation ugi

= UserGroupInformation.createRemoteUser("hbase");

ugi.doAs(new PrivilegedExceptionAction<Void>() {

public Void run() throws Exception {

Configuration conf = new Configuration();

conf.set("fs.defaultFS", " CodeGo.net

conf.set("hadoop.job.ugi", "hbase");

FileSystem fs = FileSystem.get(conf);

fs.createNewFile(new Path("/user/hbase/test"));

FileStatus[] status = fs.listStatus(new Path("/user/hbase"));

for(int i=0;i<status.length;i++){

System.out.println(status[i].getPath());

}

return null;

}

});

} catch (Exception e) {

e.printStackTrace();

}