package com.hdfs;
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.Before;
import org.junit.Test;
public class HdfsTest {
// 获取HADOOP FileSystem对象
private FileSystem fs = null;
/**
* 初始化环境变量
*/
@Before
public void init() throws Exception {
/*
* new URI("hdfs://192.168.0.131:9000"):连接HADOOP连接 RUL
* new Configuration():使用HADOOP 默认配置
* "root"：登录用户
*/
fs = FileSystem.get(new URI("hdfs://192.168.0.202:9000"),new Configuration(), "root");
}
/**
* 创建目录
*/
@Test
public void testMkdir() throws Exception {
boolean flag = fs.mkdirs(new Path("/javaApi/mk/dir1/dir2"));
System.out.println(flag ? "创建成功" : "创建失败");
}
}
java操作Hadoop源码之HDFS Java API操作-创建目录
需积分: 50 72 浏览量
2018-01-17
18:36:02
上传
评论 4
收藏 35.63MB RAR 举报
HDFS Java API操作-创建目录.rar （97个子文件） 
HDFS Java API操作-创建目录 Hadoop 
.project 365B bin com hdfs HdfsTest.class 1KB .settings org.eclipse.jdt.core.prefs 587B libs 
guava-11.0.2.jar 1.57MB hadoop-hdfs-nfs-2.4.1.jar 86KB hadoop-mapreduce-client-jobclient-2.4.1.jar 35KB avro-1.7.4.jar 296KB hadoop-annotations-2.4.1.jar 17KB snappy-java-1.0.4.1.jar 973KB hadoop-yarn-client-2.4.1.jar 105KB jersey-guice-1.9.jar 14KB hadoop-nfs-2.4.1.jar 142KB commons-beanutils-core-1.8.0.jar 201KB jetty-util-6.1.26.jar 173KB hadoop-mapreduce-examples-2.4.1.jar 264KB junit-4.10.jar 247KB commons-lang-2.6.jar 278KB leveldbjni-all-1.8.jar 1021KB hadoop-mapreduce-client-core-2.4.1.jar 1.42MB guice-3.0.jar 694KB jersey-server-1.9.jar 696KB hadoop-yarn-server-common-2.4.1.jar 209KB jasper-compiler-5.5.23.jar 399KB hadoop-yarn-server-resourcemanager-2.4.1.jar 776KB commons-math3-3.1.1.jar 1.53MB hadoop-yarn-server-nodemanager-2.4.1.jar 467KB netty-3.6.2.Final.jar 1.14MB commons-compress-1.4.1.jar 236KB jersey-json-1.9.jar 144KB hadoop-yarn-api-2.4.1.jar 1.56MB jetty-6.1.26.jar 527KB hadoop-hdfs-2.4.1.jar 6.51MB asm-3.2.jar 42KB commons-configuration-1.6.jar 292KB httpclient-4.2.5.jar 423KB hadoop-mapreduce-client-shuffle-2.4.1.jar 25KB hadoop-mapreduce-client-common-2.4.1.jar 647KB hadoop-yarn-server-tests-2.4.1.jar 2KB slf4j-log4j12-1.7.5.jar 9KB log4j-1.2.17.jar 478KB jets3t-0.9.0.jar 527KB jackson-jaxrs-1.8.8.jar 17KB commons-cli-1.2.jar 40KB commons-digester-1.8.jar 140KB hadoop-yarn-server-web-proxy-2.4.1.jar 28KB servlet-api-2.5.jar 103KB commons-el-1.0.jar 110KB commons-codec-1.4.jar 57KB jackson-core-asl-1.8.8.jar 222KB hadoop-yarn-server-applicationhistoryservice-2.4.1.jar 123KB xz-1.0.jar 92KB paranamer-2.3.jar 29KB hadoop-yarn-common-2.4.1.jar 1.34MB activation-1.1.jar 62KB commons-beanutils-1.7.0.jar 184KB hadoop-mapreduce-client-app-2.4.1.jar 477KB jaxb-api-2.2.2.jar 103KB junit-4.8.2.jar 232KB protobuf-java-2.5.0.jar 521KB hamcrest-core-1.1.jar 75KB xmlenc-0.52.jar 15KB java-xmlbuilder-0.4.jar 18KB mysql-connector-java-5.1.28.jar 855KB jline-0.9.94.jar 85KB jsr305-1.3.9.jar 32KB javax.inject-1.jar 2KB jsp-api-2.1.jar 98KB hadoop-mapreduce-client-hs-2.4.1.jar 228KB jaxb-impl-2.2.3-1.jar 869KB commons-logging-1.1.3.jar 61KB jsch-0.1.42.jar 181KB mockito-all-1.8.5.jar 1.35MB commons-io-2.4.jar 181KB commons-httpclient-3.1.jar 298KB jettison-1.1.jar 66KB jersey-client-1.9.jar 127KB jasper-runtime-5.5.23.jar 75KB hadoop-mapreduce-client-hs-plugins-2.4.1.jar 4KB stax-api-1.0-2.jar 23KB zookeeper-3.4.5.jar 762KB aopalliance-1.0.jar 4KB jersey-core-1.9.jar 448KB jackson-xc-1.8.8.jar 32KB slf4j-api-1.7.5.jar 25KB commons-net-3.1.jar 267KB hadoop-mapreduce-client-jobclient-2.4.1-tests.jar 1.42MB commons-daemon-1.0.13.jar 24KB jackson-mapper-asl-1.8.8.jar 653KB commons-collections-3.2.1.jar 562KB guice-servlet-3.0.jar 63KB hadoop-common-2.4.1.jar 2.72MB httpcore-4.2.5.jar 222KB hadoop-auth-2.4.1.jar 49KB hadoop-yarn-applications-distributedshell-2.4.1.jar 41KB hadoop-yarn-applications-unmanaged-am-launcher-2.4.1.jar 14KB src com hdfs HdfsTest.java 837B .classpath 6KB资源评论
