草庐IT

HBASE_CLASSPATH

全部标签

hadoop - HBase 无法在 Mac OSX 上以单节点集群模式启动

我正在尝试设置个人HBase开发环境。我正在运行hdfs和yarn,但无法启动HBase。我已经通过运行start-dfs.sh和start-yarn.sh启动了hadoop2.7.1。我已经通过测试hdfsdfs-mkdir/test并运行示例中捆绑的示例MR作业来验证这些正在运行,我已经在端口50070浏览了HDFS。我已经在端口2181上启动了zookeeper3.4.6并设置了它的dataDir。我的zoo.cfg有:dataDir=/Users/.../tools/hd/zookeeper_dataclientPort=2181我在我选择的dataDir中观察它的zookee

使用 HBase 作为数据接收器的 Hadoop 流式传输

我们的研究小组设置并运行了Hadoop和HBase。最近在用Hadoopstreaming(只有mappers)处理数据,想用HBase做datasink。我觉得我可以将-outputformat设置为TableOutFormat。但是在网上搜索了一段时间后,我发现具体操作可能需要很长时间才能弄清楚。下面是我的试用版:$HADOOP_HOME/bin/hadoopjar$HADOOP_HOME/hadoop-streaming.jar\-inputmyInputDirs\-outputformatHBaseLibDir/TableOutFormat\-mappermyMapperScr

database - 将记录存储在 HDFS 或 HBase 中

我有以下场景:测量数据以文件形式通过网络服务上传这些文件随后被复制到HDFS每个测量包含一个或多个参数的许多特征(值)测量值的数量可能不同使用Hadoop上的机器学习算法处理测量值并非所有测量都进行了,而是针对特定用户在特定时间段进行的(例如,对用户X在Y-Z期间上传的文件进行处理)中间结果存储在HDFS,最终结果也是如此我的问题与第二点有关-这些文件后来被复制到HDFS-我担心存在大量小文件(例如1MB)可能是个问题。我的想法是将该文件存储在数据库中,这样我就可以避免小文件的问题,并且还能够查询数据(为用户选择一段时间的数据)。这是更好的方法吗?如果答案是肯定的,我可以使用哪些数据库

mysql - Sqoop 使用 Java API 导入到 Hbase 表

我一直在尝试使用Sqoop将数据从MySQL数据库导入到Hbase,但一直遇到错误。请问你能帮我吗?(我使用的是Sqoop1)我的代码如下:importcom.cloudera.sqoop.SqoopOptions;importcom.cloudera.sqoop.tool.ImportTool;importcom.cloudera.sqoop.SqoopOptions.IncrementalMode;importcom.cloudera.sqoop.tool.SqoopTool;importorg.apache.hadoop.conf.Configuration;importorg.

hadoop - 同时使用 Delete 和 Put 时无法在 HBase 中插入新数据

我正在使用Hbasemapreduce来计算报告。在reducer中,我尝试清除“result”列族,然后添加一个新的“total”列。但我发现列族是删除的,但新数据不是插入的。Put操作似乎不起作用。你知道为什么吗?reducer类中的示例代码:Deletedel=newDelete(rowkey.getBytes());del.addFamily(RESULT);context.write(newImmutableBytesWritable(Bytes.toBytes(key.toString())),del);Putput=newPut(rowkey.getBytes());pu

hadoop - Hbase:列的自动递增

我是Hbase的新手。需要帮忙,我在Hbase中有一个包含一些数据的表。IdNameAddress1johnXX-XX2mikeXXX-XX和Id应该自动递增。现在我必须将数据插入表中,就像我们插入10条记录一样,Id应该递增到12,就像IdNameAddress1johnXX-XX2mikeXXX-XX3fooXXXX......12boooxxx可能会想到Hbase中的sequencegenerator。谁能帮我写代码。 最佳答案 HBase没有序列生成器。正如Sergey评论的那样,不推荐使用序列作为行键。当面对这样的需求时,

java - 使用 hbase 处理图像、视频和音频类型

任何人都知道如何使用Hbase处理非结构化数据,如音频、视频和图像。我为此尝试了很多,但我没有任何想法。请提供任何帮助,我们将不胜感激。 最佳答案 选项1:将图像转换为字节数组,您可以准备放置请求并插入到表中。同样也可以实现音视频文件。参见https://docs.oracle.com/javase/7/docs/api/javax/imageio/package-summary.htmlimportjavax.imageio.ImageIO;/**Convertanimagetoabytearray*/privatebyte[]c

java - Java 中的 Hbase CopyTable

我想将一个Hbase表复制到另一个性能良好的位置。我想重用来自Hbase-servergithubpage的CopyTable.java中的代码我一直在寻找hbase的文档,但它对我帮助不大http://hbase.apache.org/apidocs/org/apache/hadoop/hbase/mapreduce/CopyTable.html查看stackoverflow的这篇帖子后:Canamain()methodofclassbeinvokedinanotherclassinjava我想我可以直接使用它的主类来调用它。问题:您认为完成此副本比使用hbase-server中的C

hadoop - HBase 中有没有一种方法可以计算匹配 rowkey-search 的行

假设我的Rowkey有两部分(NUM1~NUM2)。我想按Rowkey的第一部分做一个计数组。有没有办法在HBase中执行此操作?我总是可以将其作为M/R作业读取所有行、组、计数...但我想知道是否有一种方法可以在HBase中执行此操作? 最佳答案 选项1:你可以使用prefixfilter....类似下面的内容。前缀过滤器:Thisfiltertakesoneargumentaprefixofarowkey.Itreturnsonlythosekey-valuespresentinarowthatstartswiththespec

基于hadoop的HBase JAVA API

摘要: HBase的JavaAPI提供了一种与HBase数据库进行交互的方式,通过编写Java程序可以连接到HBase集群并对数据进行存储、检索和处理。该API适用于大规模数据存储、实时数据访问和高扩展性需求的场景。具有高可靠性、高扩展性和高性能的特点。它可以处理海量数据,并且支持低延迟的读写操作,提供了强大的过滤和排序功能[1]。在当前的大数据应用环境下,HBase的优势得到了广泛认可,越来越多的企业和组织选择将其作为核心数据存储和处理平台。未来,HBase将继续发展,提升性能、可伸缩性和功能,适应新的挑战并加强与其他大数据组件的整合。一、主题概述HBase是一个开源的分布式、面向列的NoS