小编给大家分享一下HDFS基本常用命令有哪些，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！
成都创新互联公司长期为成百上千家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为渝中企业提供专业的成都网站设计、网站制作、外贸营销网站建设，渝中网站改版等技术服务。拥有十余年丰富建站经验和众多成功案例,为您定制开发。
一：查看HDFS文件的最后修改时间
public class Test6GetLTime {
/**
* 查看HDFS文件的最后修改时间
* */
public static void main(String[] args) {
try {
Configuration conf = new Configuration();
URI uri = new URI("hdfs://192.168.226.129:9000");
FileSystem fs = FileSystem.get(uri, conf);
Path dfs = new Path("hdfs://192.168.226.129:9000/");
FileStatus fileStatus = fs.getFileStatus(dfs);
long modificationTime = fileStatus.getModificationTime();
System.out.println( "Modefication time is: " + modificationTime );
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (URISyntaxException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}二：查找某个文件在HDFS集群的位置
public class Test7FileLocation {
/**
* 查找某个文件在HDFS集群的位置
* */
public static void main(String[] args) {
try {
Configuration conf = new Configuration();
URI uri = new URI("hdfs://192.168.226.129:9000");
FileSystem fs = FileSystem.get(uri, conf);
Path dfs = new Path("hdfs://192.168.226.129:9000/rootdir/ssh.txt");
FileStatus fileStatus = fs.getFileStatus(dfs);
BlockLocation[] blkLocations = fs.getFileBlockLocations(fileStatus,0, fileStatus.getLen() );
int blockLen = blkLocations.length;
System.out.println("blockLen of length : " +blockLen );
for( int i=0;i三： 获取HDFS集群上所有节点名称
public class Test8GetList {
/**
* 获取HDFS集群上所有节点名称：
* */
public static void main(String[] args) {
try {
Configuration conf = new Configuration();
URI uri = new URI("hdfs://192.168.226.129:9000");
FileSystem fs = FileSystem.get(uri,conf);
DistributedFileSystem hdfs = (DistributedFileSystem)fs;
DatanodeInfo[] dataNodeStats = hdfs.getDataNodeStats();
String[] names = new String[dataNodeStats.length];
int dataNodeLen = dataNodeStats.length;
for( int i=0; i四： 上传一个视频文件至HDFS，（ 非实时视频流）
public class UploadLive {
public static void main(String[] args) {
try {
Configuration conf = new Configuration();
URI uri = new URI("hdfs://192.168.226.129:9000");
FileSystem fs = FileSystem.get(uri, conf);
FileSystem local = FileSystem.getLocal(conf);
//确定需要上传视频流路径和接收视频流路径
Path inputDir = new Path("F:\\AHadoopTestFile");
Path hdfsFile = new Path("hdfs://192.168.226.129:9000/testhadoop/acceptLiveFile");
System.out.println( inputDir.toString());
//创建HDFS上 "acceptLiveFile" 目录 用来接收视频文件
boolean isExist = fs.exists( hdfsFile );
if( !isExist ){
fs.mkdirs(hdfsFile);
System.out.println(" 创建新的目录文件成功...");
}
FileStatus[] inputFiles = local.listStatus(inputDir);
FSDataOutputStream out;
//通过OutputStream.write()来将视频文件写入HDFS下的指定目录：
int inputFileslen = inputFiles.length;
for( int i=0;i0 ){
out.write(buffer,0,byteRead);
}
out.close();
in.close();
File file = new File( inputFiles[i].getPath().toString());
file.delete();
}
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (URISyntaxException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}以上是“HDFS基本常用命令有哪些”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注创新互联行业资讯频道！
名称栏目：HDFS基本常用命令有哪些
文章起源：http://cdkjz.cn/article/pdipsc.html
