草庐IT

HBASE_CLASSPATH

全部标签

java - 不是主机 :port while connecting hbase using java

publicclassHbaseConnectorClass{privateHTabletable;privatestaticfinalLoggerlog=LoggerFactory.getLogger(HbaseConnectorClass.class);publicstaticvoidmain(String[]args)throwsException{System.out.println("tryingtoconnect......");Configurationconf=HBaseConfiguration.create();conf.set("hbase.zookeeper.q

hadoop - 通过 Hive 外部表将 Hbase 数据索引到 solr

我已经通过Nutch2.3.1爬取了一些数据。数据存储在Hbase0.98表中。我创建了一个从hbase表导入数据的外部表。现在我必须将此数据索引到solr4.10.3。为此,我关注了this。众所周知的教程。我已经像这样创建了配置单元表createexternaltableifnotexistssolr_items(idSTRING,contentSTRING,urlSTRING,titleSTRING)ROWFORMATDELIMITEDFIELDSTERMINATEDBY'|'storedby"com.chimpler.hive.solr.SolrStorageHandler"w

java - 通过 Phoenix 连接到 Test Hbase 表

我想知道是否以及如何连接到我使用的HBaseTestTable(org.apache.hadoop.hbase.HBaseTestingUtility;)通过Phoenix。我想成功连接到Hbase,然后插入测试表并从测试表中检索数据。我已经能够创建一个HbaseTable。但无法通过Phoenix连接到它。也无法使用writeToPhoenix函数。我正在分享我写的代码:@BeforeClasspublicstaticvoidinit()throwsException{testingUtility=newHBaseTestingUtility();testingUtility.sta

java - 无法通过Java连接到Hbase

我正在尝试从Java连接到Hbase。Hbase-版本1.0.0但我无法连接它。请告诉我我缺少什么,因为我是Hbase的新手。这是我的代码publicclassHbaseAddRetrieveData{publicstaticvoidmain(String[]args)throwsIOException{TableNametableName=TableName.valueOf("stock-prices");Configurationconf=HBaseConfiguration.create();conf.set("hbase.master","LocalHost:60000");c

hadoop - 将 Hbase 导入 Hive

我正在尝试将数据从Hbase移动到Hive。下面是我的代码CREATETABLEhbase_hive(keystring,firstnamestring,agestring)STOREDBY‘org.apache.hadoop.hive.hbase.HBaseStorageHandler’WITHSERDEPROPERTIES(“hbase.columns.mapping”=“id:firstname,id:age")TBLPROPERTIES(“hbase.table.name”=“hl”);但是我得到了波纹管错误FAILED:ParseExceptionline2:10mismat

hadoop - 使用 HBase-Hive 集成删除值

我正在使用HBase-Hive集成,通过Hive读写HBase,遵循documentation.基本上,我使用HBaseStorageHandler在Hive中创建一个表,例如:CREATEEXTERNALTABLEhbase.test(col1string,col2map)STOREDBY'org.apache.hadoop.hive.hbase.HBaseStorageHandler'WITHSERDEPROPERTIES('hbase.columns.mapping'=':key,cf:','hbase.table.name'='test')它在读取和写入方面运行良好。但是现在我

hadoop - HFileOutputFormat2.configureIncrementalLoad 与 HBASE 中的 HFileOutputFormat.configureIncrementalLoad 之间的区别

您能告诉我HBASE中的HFileOutputFormat2.configureIncrementalLoad与HFileOutputFormat.configureIncrementalLoad之间有什么区别,因为这两种方法都可以正常工作?性能有提升吗? 最佳答案 如果您使用这两个类共存的HBase版本(0.96+),那么它们之间绝对没有区别。您可以查看HFileOutputFormat的代码并看到HFileOutputFormat.configureIncrementalLoad只是从HFileOutputFormat2调用相同

hadoop - HBASE有哪些性能提升技术?

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭5年前。Improvethisquestion它可以是在创建表时或在使用其他查询(如在表上插入、更新、删除)时。我知道使用BloomFilter、BlockCache等选项会产生影响。但我想知道其他可以提高整体吞吐量的技术。任何人都可以展示如何在Hbase表上添加BloomFilter。我想尝试一下练习。感谢任何帮助。

java - 如何将 pdf/images 存储到 HBase 表

我是HBase的新手。以下是我想要实现的目标:1.如何将.pdf或.png转成hbase可读格式?2、如何将这些文件导入到hbase表中?(将元数据存储在一个cf中,将对象存储在另一个cf中)任何人都可以分享这方面的例子吗?任何其他建议都有帮助。 最佳答案 图片见我的answer.对于PDF这也将起作用,因为我们正在尝试以最原始的方式存储字节数组。建议您使用SerializationUtils对于pdf,如我在答案中的示例中所述。或使用ApacheCommonsIOorg.apache.commons.io.FileUtils.re

rest - Hbase REST API : Timerange scan

问:如何使用RESTAPI扫描给定时间范围内的Hbase?我试过这段代码:{"type":"PrefixFilter","value":"NThiMDNjYWRlNTc5NmIwOWI0OGViMTdl",//base64encoded"58b03cade5796b09b48eb17e""timerange":["1489502797781","1489502797788"]}Hbaseshelltimerange扫描是:>scan'tableName',{TIMERANGE=>[1489442551458,1489442551558]}将时间戳编码为base64无效,字符串化数组并将