草庐IT

hbase-client

全部标签

hadoop - ImportTsv-HBASE 批量加载时出错

我有hbase0.94.0。我尝试使用importtsv工具进行批量导入。这是我给的命令./hadoopjar/home/ericsson/Desktop/ProjectFiles/hbase-0.94.0/hbase-0.94.0.jarimporttsv-Dimporttsv.columns=HBASE_ROW_KEY,a,b,c,d,e,f,g'-Dimporttsv.separator=,'Test1/home/ericsson/Desktop/ProjectFiles/inputFiles1/CharginUsage-m-00000Test1-我的表已经存在于Hbase中。/

hadoop - 为什么 HIVE 依赖于服务器 URL 和 HBase?

我注意到HIVE在扫描bigtop集成测试时有很多依赖项,包括服务器url和HBASE。参见:https://github.com/cloudera/bigtop/blob/master/test/src/smokes/hive/src/test/groovy/com/cloudera/itest/hivesmoke/TestJdbcDriver.java无论如何,我想知道——最初Hive似乎本质上是一种将SQL声明转换为MapReduce作业的方法。在Hive操作世界中,hbase和“hive服务器”的作用是什么?Hive可以独立作为SQL->MapReduce客户端,还是这些硬性的

hadoop - 如何在 Hbase Scan 中跳过行?

我正在实现一个简单的分页,比如转到第1页、第2页、第3页等等。在HBaseBook中,我读到有一个PageFilter有一个构造函数,其中一个参数指示要返回的行数,但问题是如何去,例如,直接跳过pageSize*currentPageNumber行到第5页?HBase书中给出的示例似乎是序列分页,即您可以直接转到第5页。有没有办法在HBase中跳过行?提前致谢。 最佳答案 PageFilter不提供任何偏移功能,它的工作方式就像一个限制子句,当您有足够的数据时停止扫描操作。重要的是要说HBase不知道一个表有多少行,您必须扫描整个表

hadoop - 为区域服务器(HBase)寻找事件线程

有没有办法找到Hbase中特定regionServer的所有事件线程?我想看看是什么导致了特定节点的瓶颈。提前致谢。 最佳答案 在RegionServer上找到您感兴趣的Java进程-即与HBase相关的所有内容。jvm提供了一个方便的实用程序来执行此操作,称为“jps”。这是一些示例输出:jps-l18863sun.tools.jps.Jps2584/opt/eclipse//plugins/org.eclipse.equinox.launcher_1.3.0.v20140415-2008.jar获得所需的进程后,使用“jstac

xml - 将 XML 放入 HBase 的正确方法

我正在尝试将一些本地存储的XML文件放入HBase(版本1.1.X)中。我的目标是使用MapReduce(无缩减阶段)将这些XML的内容作为字符串存储在我的HBase表中,而不将它们加载到HDFS。这是我的伪代码:fetchXMLs(path);XML2OneLineFile();configureHBase();//+establishingconnectionMap(input,output);//input:oneXMLfileinoneline;output:isthePut()ofHBase;closeConnection();这种解决问题的方法是否正确,或者有更好的方法吗?

hadoop - Flink 从 hbase 读取时出现序列化错误

当我在map中使用richfatMapFunction从hbase读取时,出现序列化错误。我想要做的是,如果数据流等于从hbase读取的特定字符串,则忽略。下面是示例程序和我遇到的错误。packagecom.abb.Flinktestimportjava.text.SimpleDateFormatimportjava.util.Propertiesimportscala.collection.concurrent.TrieMapimportorg.apache.flink.addons.hbase.TableInputFormatimportorg.apache.flink.api.c

hadoop - Hbase checkAndPut 和 checkAndMutate 有什么区别?

在Hbase1.2.4中checkAndPut和checkAndMutate有什么区别? 最佳答案 checkAndPut-根据传递的CompareOp将值与来自hbase的当前值进行比较。CompareOp=EQUALS如果预期值相等,则将值添加到put对象。checkAndMutate-根据传递的CompareOp.CompareOp=EQUALS将值与来自hbase的当前值进行比较,如果预期值相等,则将值添加到rowmutation对象。您可以按照希望在hbase中执行突变的顺序向rowmutation对象添加多个put和de

hadoop - 我可以在 HBase 的 rowkey 上使用 SingleColumnValueFilter 吗?

HBase版本:1.2.2(服务器和JavaAPI)publicSingleColumnValueFilter(byte[]family,byte[]qualifier,CompareFilter.CompareOpcompareOp,ByteArrayComparablecomparator)我正在使用org.apache.hadoop.hbase.filter.RegexStringComparator对rowkey执行LIKE查询。它可以很好地处理列。但如果我使用行键而不是列,它会为我提供所有记录。 最佳答案 ColumnVa

hadoop - Hbase region数量持续增长

我们使用的是hbase版本1.1.4。该数据库有大约40个表,每个表数据都指定了TimeToLive。部署在一个5节点的集群上,下面是hbase-site.xmlphoenix.query.threadPoolSize2048hbase.hregion.max.filesize21474836480hbase.hregion.memstore.block.multiplier4hbase.hregion.memstore.flush.size536870912hbase.hstore.blockingStoreFiles240hbase.client.scanner.caching10

hadoop - 如何查看hbase数据库中使用的表?

我是hbase的新手。hbase中创建了30个表。我想查看那些表结构。我已经使用下面的命令查看表格,但只有一张表格。希望我需要连接到hbase中的正确数据库以列出表。hbase(main):017:0>listTABLEtest1row(s)in0.0140seconds现在我想让命令知道hbase中存在(已经创建)的数据库是什么? 最佳答案 为了与HBase术语保持一致...有一个“命名空间”的概念。您可以在特定命名空间下创建表。Groupname:namespaceCommands:alter_namespace,create_