小编给大家分享一下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