1.要成为一名大数据开发工程师必备哪些技能?
2.å¦ä½å¨windowså¹³å°ä¸ç¨Eclipseè°è¯è¿è¡HBase
3.javaåç½ç«ç¨ä»ä¹è½¯ä»¶ï¼
4.eclipse中Java程序实现对HBase操作报错:java.io.IOException: Attempt to start meta tracker failed.
要成为一名大数据开发工程师必备哪些技能?
首先我们要了解Java语言和Linux操作系统,这两个是学习大数据的基础,学习的顺序不分前后。大数据
Java :只要了解一些基础即可,做大数据不需要很深的Java 技术,学java SE 就相当于有学习大数据基础。龙凤和鸣主图指标公式源码
Linux:因为大数据相关软件都是在Linux上运行的,所以Linux要学习的扎实一些,学好Linux对你快速掌握大数据相关技术会有很大的帮助,能让你更好的理解hadoop、hive、hbase、spark等大数据软件的运行环境和网络环境配置,能少踩很多坑,学会shell就能看懂脚本这样能更容易理解和配置大数据集群。还能让你对以后新出的大数据技术学习起来更快。
Hadoop:这是现在流行的大数据处理平台几乎已经成为大数据的代名词,所以这个是必学的。Hadoop里面包括几个组件HDFS、订单录入源码MapReduce和YARN,HDFS是存储数据的地方就像我们电脑的硬盘一样文件都存储在这个上面,MapReduce是对数据进行处理计算的,它有个特点就是不管多大的数据只要给它时间它就能把数据跑完,但是时间可能不是很快所以它叫数据的批处理。
Zookeeper:这是个万金油,安装Hadoop的HA的时候就会用到它,以后的Hbase也会用到它。它一般用来存放一些相互协作的搜狗引流源码信息,这些信息比较小一般不会超过1M,都是使用它的软件对它有依赖,对于我们个人来讲只需要把它安装正确,让它正常的run起来就可以了。
Mysql:我们学习完大数据的处理了,接下来学习学习小数据的处理工具mysql数据库,因为一会装hive的时候要用到,mysql需要掌握到什么层度那?你能在Linux上把它安装好,运行起来,大型源码平台会配置简单的权限,修改root的密码,创建数据库。这里主要的是学习SQL的语法,因为hive的语法和这个非常相似。
Sqoop:这个是用于把Mysql里的数据导入到Hadoop里的。当然你也可以不用这个,直接把Mysql数据表导出成文件再放到HDFS上也是一样的,当然生产环境中使用要注意Mysql的延时EA源码压力。
Hive:这个东西对于会SQL语法的来说就是神器,它能让你处理大数据变的很简单,不会再费劲的编写MapReduce程序。有的人说Pig那?它和Pig差不多掌握一个就可以了。
Oozie:既然学会Hive了,我相信你一定需要这个东西,它可以帮你管理你的Hive或者MapReduce、Spark脚本,还能检查你的程序是否执行正确,出错了给你发报警并能帮你重试程序,最重要的是还能帮你配置任务的依赖关系。我相信你一定会喜欢上它的,不然你看着那一大堆脚本,和密密麻麻的crond是不是有种想屎的感觉。
Hbase:这是Hadoop生态体系中的NOSQL数据库,他的数据是按照key和value的形式存储的并且key是唯一的,所以它能用来做数据的排重,它与MYSQL相比能存储的数据量大很多。所以他常被用于大数据处理完成之后的存储目的地。
Kafka:这是个比较好用的队列工具,队列是干吗的?排队买票你知道不?数据多了同样也需要排队处理,这样与你协作的其它同学不会叫起来,你干吗给我这么多的数据(比如好几百G的文件)我怎么处理得过来,你别怪他因为他不是搞大数据的,你可以跟他讲我把数据放在队列里你使用的时候一个个拿,这样他就不在抱怨了马上灰流流的去优化他的程序去了,因为处理不过来就是他的事情。而不是你给的问题。当然我们也可以利用这个工具来做线上实时数据的入库或入HDFS,这时你可以与一个叫Flume的工具配合使用,它是专门用来提供对数据进行简单处理,并写到各种数据接受方(比如Kafka)的。
Spark:它是用来弥补基于MapReduce处理数据速度上的缺点,它的特点是把数据装载到内存中计算而不是去读慢的要死进化还特别慢的硬盘。特别适合做迭代运算,所以算法流们特别稀饭它。它是用scala编写的。Java语言或者Scala都可以操作它,因为它们都是用JVM的。
å¦ä½å¨windowså¹³å°ä¸ç¨Eclipseè°è¯è¿è¡HBase
ããæä½æ¥éª¤å¦ä¸ï¼ãã1.ä¸è½½åå®è£ cygwinï¼
ãã2.ä¸è½½æ°çZookeeperå åHBaseå ï¼è¿éZooKeeperçæ¬ä¸º3.3.1ï¼HBaseçæ¬ä¸º0..4
ãã3.æå©ç¨å®ä»¬çæºç å å¨Eclipseä¸çæ2个ç¬ç«çProject,注æï¼zookeeperå·¥ç¨ï¼è¦æé£ä¸ªconfç®å½å å ¥å°å·¥ç¨çsrcä¸å»
ãã4.ä¿®æ¹zookeeperå·¥ç¨ä¸çconfç®å½ä¸çzoo.cfgæ件ï¼ä¾åå¦ä¸ï¼
ãã# The number of milliseconds of each tick
ããtickTime=
ãã# the directory where the snapshot is stored.
ããdataDir=D:/zookeeper-3.3.1/data
ãã# the port at which the clients will connect
ããclientPort=
ããå°±æ¯ç»zookeeperæå®æ件åæ¾çå°æ¹ä»¥å端å£
ãã5.å¯å¨zookeeper
ããå¨Eclipseä¸æ°å»ºä¸ä¸ªRun configï¼main class为ï¼org.apache.zookeeper.server.quorum.QuorumPeerMain
ããå¯å¨çç¨åºåæ°ä¸ºï¼D:/workspace/zookeeper3.3.1/conf/zoo.cfg
ããå¯å¨çèææºåæ°ä¸ºï¼
ãã-Dzookeeper.log.dir=D:/workspace/zookeeper3.3.1/log
ãã-Dzookeeper.root.logger=INFO,CONSOLE
ããå¦å¾æ示ï¼
ãã好äºï¼è¿æ ·å°±å¯ä»¥å¨Eclipseä¸æZooKeeperå¯å¨èµ·æ¥äºã
ãã6.ä¿®æ¹HBase projectä¸çä¸ä¸ªç±»
ããorg.apache.hadoop.hbase.LocalHBaseCluster
ããæ¾å°å®çmainå½æ°ï¼æmainå½æ°æ¹æä¸
ããpublic static void main(String[] args) throws IOException {
ããHBaseConfiguration conf = new HBaseConfiguration();
ããconf.set("hbase.zookeeper.quorum", "localhost");
ããconf.set("hbase.zookeeper.property.clientPort", "");
ããLocalHBaseCluster cluster = new LocalHBaseCluster(conf,1);
ããcluster.startup();
ãã}ãã
ãã注æè¡ï¼LocalHBaseCluster cluster = new LocalHBaseCluster(conf,1); æé å½æ°ä¸ç1æ¯ä»£è¡¨Region serverç个æ°ï¼å¨è¿éåªæ³èµ·ä¸ä¸ªregion server.
ãã7.ä¿®æ¹HBaseçé ç½®æ件
ããå¨HBase projectä¸çsrcä¸å¯ä»¥çå°hbase-default.xmlåhbase-site.xml两个æ件ï¼æ¹åªä¸ªé½å¯ä»¥ãç´æ¥å¨hbase-default.xmlæ¹çï¼éè¦çæ¯ä¸é¢3个å±æ§hbase.rootdirï¼hbase.cluster.distributedï¼hbase.tmp.dirï¼
ããæhbase.rootdirï¼hbase.tmp.diré½æåäºæ¬å°çç®å½ï¼å½ç¶å¯ä»¥æ ¹æ®èªå·±çéè¦è°æ´,å½ç¶æ ¼å¼ä¸å®ä¸æ ·åã
ãã<property>
ãã<name>hbase.rootdir</name>
ãã<value>file:///D:/hbase-0..3/data </value>
ãã<description>The directory shared by region servers.
ããShould be fully-qualified to include the filesystem to use.
ããE.g: hdfs://NAMENODE_SERVER:PORT/HBASE_ROOTDIR
ãã</description>
ãã</property>
ãã<property>
ãã<name>hbase.cluster.distributed</name>
ãã<value>false </value>
ãã<description>The mode the cluster will be in. Possible values are
ããfalse: standalone and pseudo-distributed setups with managed Zookeeper
ããtrue: fully-distributed with unmanaged Zookeeper Quorum (see hbase-env.sh)
ãã</description>
ãã</property>
ãã<property>
ãã<name>hbase.tmp.dir</name>
ãã<value>D:/hbase-0..3/tmp </value>
ãã<description>Temporary directory on the local filesystem.</description>
ãã</property>
ãã<property>ãã
ãã8.å¯å¨HBaseï¼ç´æ¥run org.apache.hadoop.hbase.LocalHBaseClusterå°±å¯ä»¥ï¼run configä¸éè¦æ²¡æä»ä¹å«çé ç½®ãå½ç¶å°±ä¹å¯ä»¥debugäºã
javaåç½ç«ç¨ä»ä¹è½¯ä»¶ï¼
JAVAè¯è¨å¦ä¹ 主è¦å¯ä»¥å¼åä»ä¹ï¼
1ãJavaå¯ä»¥åç½ç«
Javaå¯ä»¥ç¨æ¥ç¼åç½ç«ï¼ç°å¨å¾å¤å¤§åç½ç«é½ç¨Jspåçï¼JSPå ¨åJavaServerPagesã
å®æ¯ä¸ç§å¨æç½é¡µææ¯ï¼æ¯å¦æ们çæçï¼ä¸äºæ¿åºç½ç«é½æ¯éç¨JSPç¼åçã
æ以å¦ä¹ Javaçåå¦å¯ä»¥æ¾å¼åç½ç«æ¹é¢çå·¥ä½ï¼èä¸ç°å¨æ¾è¿æ¹é¢çå²ä½æ¯è¾å¤ã
æ¯å¦ï¼ç½ç«å¼åï¼å½ç¶å°±æ¯JSP+Servlet+JavaBeanï¼ä¸ç´ä»¥æ¥é½ç¸å½æµè¡ã
2ãJavaå¯ä»¥åAndroid
Androidæ¯ä¸ç§åºäºLinuxçèªç±åå¼æ¾æºä»£ç çæä½ç³»ç»ï¼å ¶æºä»£ç æ¯Javaã
æ以å¸åºä¸è§å°çææºç³»ç»ä¾å¦MIUI,é¿éäºï¼ä¹èçï¼é½æ¯ä¿®æ¹æºä»£ç ååè¡çã
Javaåå®åä¸ååæ¯æç³»ç»ï¼è¿æAPP对äºæ´å¤çå¼å人åæ¥è¯´ï¼ä»ä»¬æ´å¤çæ¶é´æ¯è±å¨å¼åAPPä¸é¢ã
3ãJavaå¯ä»¥å游æ
æè ä½ ä¸ç¥éï¼å¨ä»¥å诺åºäºè¿å¾æµè¡çæ¶åï¼ä½ ç©çææºæ¸¸ææ%以ä¸é½æ¯Javaå¼åçã
å½ç¶ç°å¨å·²ç»å¾å°äººåå»å¼åäºï¼é½è½¬å°å®åä¸å»äºã
çµèä¸ä¹æjavaå¼åç游æï¼æç»å ¸çæ¯ï¼ãæçä¸çã(minecraftï¼ç®ç§°MC)ã
4ãJavaå¯ä»¥å软件
ä¸è¬ç¼ç¨è¯è¨é½å¯ä»¥å软件çï¼Javaä¹ä¸ä¾å¤ï¼ä¾å¦Eclipseï¼MyEclipseçç¥åJavaå¼åå·¥å ·.æå ³å¼å软件ç»ä»¶ï¼å¯ä»¥äºè§£JavaSwingç¼ç¨æè awtç¸å ³ç¥è¯ã
æ¯å¦ï¼ä¼ä¸çº§åºç¨å¼åï¼è¿éæ¯JAVAç天å°ï¼å¤§å°å ¨å½èç½çç³»ç»ï¼å°å°ä¸å°ä¼ä¸çåºç¨è§£å³æ¹æ¡ï¼Javaé½å ææ为éè¦çå°ä½ã
å¦å¤è¿æ移å¨é¢åï¼å ¸åçåºç¨æ¯ææºæ¸¸æ(å½å 主è¦æ¯è¿æ¹é¢)ï¼è¿éæ¯J2MEç天å°ï¼å ¶å®åºç¨èå´æ¯å¾å¹¿çã
å¦ä½ç¨Javaåç½ç«ï¼
javaç¨æ¥å¶ä½ç½ç«ï¼ä¸è¬æ¯ä½¿ç¨ç°æçæ¡æ¶ï¼å¦ä¸ï¼
javaå¯ä»¥ç¨æ¥åç½ç«
javaå¼åå¹³å°ä¸è¬æä¸ä¸ªçæ¬ï¼å ¶ä¸javaeeç¨æ¥ç½ç«å¼å
*JavaSEï¼JavaPlatformï¼StandardEditionï¼ãJavaSE以å称为J2SEãå®å 许å¼ååé¨ç½²å¨æ¡é¢ãæå¡å¨ãåµå ¥å¼ç¯å¢åå®æ¶ç¯å¢ä¸ä½¿ç¨çJavaåºç¨ç¨åºãJavaSEå å«äºæ¯æJavaWebæå¡å¼åçç±»ï¼å¹¶ä¸ºJavaPlatformï¼EnterpriseEditionï¼JavaEEï¼æä¾åºç¡ã
*JavaEEï¼JavaPlatformï¼EnterpriseEditionï¼ãè¿ä¸ªçæ¬ä»¥å称为J2EEãä¼ä¸çæ¬å¸®å©å¼ååé¨ç½²å¯ç§»æ¤ãå¥å£®ãå¯ä¼¸ç¼©ä¸å®å ¨çæå¡å¨ç«¯Javaåºç¨ç¨åºãJavaEEæ¯å¨JavaSEçåºç¡ä¸æ建çï¼å®æä¾Webæå¡ãç»ä»¶æ¨¡åã管çåéä¿¡APIï¼å¯ä»¥ç¨æ¥å®ç°ä¼ä¸çº§çé¢åæå¡ä½ç³»ç»æï¼service-orientedarchitectureï¼SOAï¼åWeb2.0åºç¨ç¨åºã
*JavaMEï¼JavaPlatformï¼MicroEditionï¼ãè¿ä¸ªçæ¬ä»¥å称为J2MEãJavaME为å¨ç§»å¨è®¾å¤ååµå ¥å¼è®¾å¤ï¼æ¯å¦ææºãPDAãçµè§æºé¡¶çåæå°æºï¼ä¸è¿è¡çåºç¨ç¨åºæä¾ä¸ä¸ªå¥å£®ä¸çµæ´»çç¯å¢ãJavaMEå æ¬çµæ´»çç¨æ·çé¢ãå¥å£®çå®å ¨æ¨¡åã许å¤å ç½®çç½ç»å议以å对å¯ä»¥å¨æä¸è½½çè¿ç½å离线åºç¨ç¨åºç丰å¯æ¯æãåºäºJavaMEè§èçåºç¨ç¨åºåªéç¼åä¸æ¬¡ï¼å°±å¯ä»¥ç¨äºè®¸å¤è®¾å¤ï¼èä¸å¯ä»¥å©ç¨æ¯ä¸ªè®¾å¤çæ¬æºåè½ã
å¦ä¹ Javaå¯ä»¥åä»ä¹ï¼å¦ä¹ Javaå¯ä»¥åä»ä¹ï¼Java并ä¸æ¯ä¸ºInternet,WWWè设计çï¼å®ä¹å¯ä»¥ç¨æ¥ç¼åç¬ç«çåºç¨ç¨åºãJavaæ¯ä¸ç§é¢å对象è¯è¨ãJavaè¯è¨ç±»ä¼¼äºC++è¯è¨ï¼æ以已çç»ææ¡C++è¯è¨çç¼ç¨äººåï¼åå¦ä¹ Javaè¯è¨å°±å®¹æå¾å¤ï¼Javaç¨åºéè¦ç¼è¯ãå®é ä¸æ两ç§Javaç¨åºï¼ä¸ç§Javaåºç¨ç¨åºæ¯ä¸ä¸ªå®æ´çç¨åºï¼å¦Webæµè§å¨ãä¸ç§Javaå°åºç¨ç¨åºæ¯è¿è¡äºWebæµè§å¨ä¸çä¸ä¸ªç¨åºãä¸é¢å ·ä½ä»ç»ä¸ä¸å¦ä¹ Javaä¹åå¯ä»¥åä»ä¹ï¼
ä¸ãå¦ä¹ Javaå¯ä»¥åä»ä¹ï¼Javaå¯ä»¥ç¨æ¥åç½ç«
Javaå¯ä»¥ç¨æ¥åç½ç«ï¼å¾å¤å¤§åç½ç«é½æ¯ç¨JSPåçï¼JSPå ¨åJavaServerPagesãè¿æ¯ä¸ç§å¨æç½é¡µææ¯ï¼æ¯å¦æ们çæçBç«ï¼å¾å¤æ¿åºç½ç«é½æ¯ç¨è¿ä¸ªåçæ以æ³å¦ä¹ Javaçåå¦è¿å¯ä»¥è´è´£ç½ç«æ¹é¢çå¶ä½ï¼è¿æ¹é¢çå²ä½ä¹æ¯è¾å¤ï¼æ¯å¦:ç½ç«å¼åï¼å½ç¶å°±æ¯JSP+Servlet+JavaBeanï¼ä¸ç´ä»¥æ¥é½ç¸å½æµè¡ã
äºãå¦ä¹ Javaå¯ä»¥åä»ä¹ï¼Javaå¯ä»¥åå®å软件
å®åæ¯ä¸ä¸ªææºç³»ç»åºäºLinuxçæä½ç³»ç»ï¼å ¶ä¸æºä»£ç Javaï¼å¸é¢ä¸ææçå®åææºï¼å æ¬å°ç±³ï¼oppoï¼å为ææºç³»ç»é½æ¯ä¿®æ¹Javaè¿è¡çï¼Javaåå®åä¹ä¸åªæ¯åªè½åç³»ç»ï¼å¯¹äºæ´å¤çç¨åºå¼å人åæ¥è¯´ï¼æ´å¤çæ¶é´æ¯è±å¨APPä¸ï¼ä¹å°±æ¯ææºä¸çåç§è½¯ä»¶é½æ¯ç¨Javaåçï¼Javaåå®åä¸ååæ¯æç³»ç»ï¼è¿æAPP对äºæ´å¤çå¼å人åæ¥è¯´ï¼ä»ä»¬æ´å¤çæ¶é´æ¯è±å¨å¼åAPPä¸é¢ãå¦æä½ è¿å¨å¯»æ¾Javaå¨åªè¿ç¨ï¼ä½ ä¸ç¨ä¸å¥è¥¿èµ°ç寻æ¾ï¼ä½ ç身边就æ¯ãAndroidææºï¼é便æå¼ä¸ä¸ªAppåºç¨ï¼ä»ä»¬å°±æ¯ç¨Javaè¯è¨ï¼ä»Googleä¸æç´¢AndroidçAPIææ¡£ï¼ä½ å°±ä¼åç°å®åJavaçJDKææ¡£æ人çç¸ä¼¼ã
ä¸ãå¦ä¹ Javaå¯ä»¥åä»ä¹ï¼Javaå¯ä»¥ç¨æ¥å游æ
以å诺åºäºææºé£é¡å¤©ä¸çæ¶åï¼ä¸é¢çå¾å¤å°æ¸¸æé½æ¯ç¨Javaåçï¼åªæ¯ç°å¨é½å¤å»å¼åå®åäºï¼çµèä¸ç大å¤æ°ä¹æ¯ç¨Javaæ¥å¼åçï¼æç»å ¸çå°±æ¯ãæçä¸çãï¼å½ä»ä¸çæå ·å½±ååç游æè±éèçï¼å鸡就æ¯ç¨Javaåç
åãå¦ä¹ Javaå¯ä»¥åä»ä¹ï¼Javaå¯ä»¥ç¨æ¥å软件
å¾å¤ç¼ç¨è¯è¨é½æ¯å¯ä»¥æ¥å软件çï¼ä½Javaæ¯ç°å¨æéç¨æ广æ³çï¼æ¯å¦ï¼ä¼ä¸çº§åºç¨å¼åï¼è¿éæ¯Javaç天å°ãè¿æOAãé®ç®±ãæ票ãéèãèè¯ãç©æµãå»çãç¿å±±çä¿¡æ¯æ¹é¢çç³»ç»ï¼Javaé½å ææ为éè¦çå°ä½ãç°å¨å½å çæçé¨çå°±æ¯ææºåºç¨ï¼å¦ä¹ Javaå»åææºåºç¨è¿æ¯æ¯è¾åé¦çï¼æ¯å¦ï¼ä¼ä¸çº§åºç¨å¼åï¼è¿éæ¯Javaç天å°ï¼å¤§å°å ¨å½èç½çç³»ç»ï¼å°å°ä¸å°ä¼ä¸çåºç¨è§£å³æ¹æ¡ï¼Javaé½å ææ为éè¦çå°ä½ï¼å¦å¤è¿æ移å¨é¢åï¼å ¸åçåºç¨æ¯ææºæ¸¸æ(å½å 主è¦æ¯è¿æ¹é¢)ï¼è¿éæ¯J2MEç天å°ï¼å ¶å®åºç¨èå´æ¯å¾å¹¿çã
äºãå¦ä¹ Javaå¯ä»¥åä»ä¹ï¼Javaæå¡å¨ç¨åº
Javaå¨éèæå¡ä¸çåºç¨é常广æ³ï¼è®¸å¤è·¨å½æèµé¶è¡ä¾å¦ï¼GoldmanSachs(é«çæèµ)ï¼Citigroup(è±æéå¢)ï¼Barclays(å·´å è±é¶è¡)以åå ¶ä»é¶è¡ï¼é½ç¨Javaæ¥ç¼ååå°ååå°ççµå交æç³»ç»ï¼ç»ç®å确认系ç»ï¼æ°æ®å¤ç项ç®ä»¥åå ¶ä»é¡¹ç®ã
大å¤æ°æ åµä¸ï¼Java被ç¨å¨æå¡å¨ç«¯å¼åï¼ä½å¤æ°æ²¡æä»»ä½å端ï¼å®ä»¬é常æ¯ä»ä¸ä¸ªæå¡å¨(ä¸ä¸çº§)æ¥æ¶æ°æ®ï¼å¤çåååå¦ä¸ä¸ªå¤çç³»ç»(ä¸ä¸çº§å¤ç)ã
å ãå¦ä¹ Javaå¯ä»¥åä»ä¹ï¼Java大æ°æ®ææ¯
Hadoop以åå ¶ä»å¤§æ°æ®å¤çææ¯é½æ¯ç¨Javaæè å ¶ä»ï¼ä¾å¦ApacheçåºäºJavaçHBaseåAccumulo以åElasticSearchasãä½æ¯Javaå¨æ¤é¢å并æªå 太大空é´ï¼ä½åªè¦HadoopåElasticSearchasè½å¤æé¿å£®å¤§ï¼Javaä¾æ§è¿ææ½åå»å¨è¿ä¸ªå¸åºå æ®ä¸é¨åã
éè¿ä¸é¢çä»ç»å¯¹äºå ·ä½Javaæ¯åä»ä¹çç±æ¥ä¸å®çäºè§£å认è¯ï¼é£ä¹å¯¹äºæ¥æJavaææ¯çç¨åºåæ¥è¯´ï¼èä¸éè·¯çéæ©ååç宽广ï¼è¡ä¸åæ¯ä¹å¹¿éé½æ¯å¯ä»¥é¢è§ãæ以ï¼èµ¶å¿«æä½æºéæ¥ææå大éé¸Javaå¼åå¹è®çå¦Javaå¼åå§ï¼
eclipse中Java程序实现对HBase操作报错:java.io.IOException: Attempt to start meta tracker failed.
我hadoop和Hbase都是采用伪分布式的
代码如下:
public class HbaseTest {
private static Configuration conf;
static{
conf = HBaseConfiguration.create();
conf.set("hbase.rootdir", "hdfs://...2:/hbase");
//使用eclipse时必须添加这个,否则无法定位
conf.set("hbase.zookeeper.quorum", "...2");
conf.set("hbase.zookeeper.property.clientPort", "");
}
public static void createTable(String tableName){
System.out.println("start create table ......");
try {
HBaseAdmin hbAdmin = new HBaseAdmin(conf);
if(hbAdmin.tableExists(tableName)){
hbAdmin.disableTable(tableName);
hbAdmin.deleteTable(tableName);
System.out.println(tableName + " is exist,detele ....");
}
// HTableDescriptor htd = new HTableDescriptor(tableName);
HTableDescriptor htd = new HTableDescriptor(tableName);
htd.addFamily(new HColumnDescriptor("cf1"));
htd.addFamily(new HColumnDescriptor("cf2"));
htd.addFamily(new HColumnDescriptor("cf3"));
htd.addFamily(new HColumnDescriptor("cf4"));
hbAdmin.createTable(htd);
} catch (MasterNotRunningException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ZooKeeperConnectionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("end create table ......");
}
public static void main(String[] args) {
createTable("testTable");
}
更多0