Tag: hbase

将Jar文件添加到WEB-INF / lib

我是Eclipse，Java和Linux的新手。 我搜索这个问题，但我没有回答。 我想编写一个操作HBase表的程序。 所以我有一些与HBase相关的Jar文件。 在普通的Java应用程序中，我通过以下指令添加Jar文件 构建路径 – >配置构建路径 – >添加外部JAR 所以在Dynamic Web Project中声音不同。 经过一些搜索后，我了解Jar文件必须添加到WEB-INF / lib或％TOMCAT_HOME％/ lib中。 所以我从％TOMCAT_HOME％/ lib得到答案，但真的很困惑如何在WEB-INF / lib中添加jar文件。 我复制文件夹中的所有jar文件，但它不起作用。 请帮我详细一点。

HBase 0.92在Windows上使用Cygwin独立

有没有人知道在Cygwin下如何在Windows上运行HBase的教程？ 我设法设置所有内容，例如使用SSH自动登录的密钥，但我坚持以下错误消息： localhost: +======================================================================+ localhost: | Error: JAVA_HOME is not set and Java could not be found | localhost: +———————————————————————-+ localhost: | Please download the latest Sun JDK from the Sun Java web site | localhost: | > http://java.sun.com/javase/downloads/ < | localhost: | | localhost: | HBase requires Java 1.6 or later. | localhost: | […]

如何使用java api直接发送hbase shell命令，如jdbc？

如何使用java api直接发送hbase shell命令 ， 如jdbc ？ public static void main(String args[]) { // get Connection to connect hbase Connection conn = ….; // hbase shell command String cmd = “get ‘t1’,’r1′”; Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(cmd); while(rs.next()) { … } } 如果没有这个的java api，还有另一种方法来实现目标吗？

适用于Secure Hbase的Java客户端

嗨，我正在尝试为安全的hbase编写一个java客户端。 我想从代码本身做kinit，因为我使用的是用户组信息类。 任何人都可以指出我在哪里错了吗？ 这是我试图连接o hbase的主要方法。 我必须在CONfiguration对象中添加配置而不是使用xml，因为客户端可以位于任何位置。 请参阅以下代码： public static void main(String [] args) { try { System.setProperty(CommonConstants.KRB_REALM, ConfigUtil.getProperty(CommonConstants.HADOOP_CONF, “krb.realm”)); System.setProperty(CommonConstants.KRB_KDC, ConfigUtil.getProperty(CommonConstants.HADOOP_CONF,”krb.kdc”)); System.setProperty(CommonConstants.KRB_DEBUG, “true”); final Configuration config = HBaseConfiguration.create(); config.set(CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHENTICATION, AUTH_KRB); config.set(CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION, AUTHORIZATION); config.set(CommonConfigurationKeysPublic.FS_AUTOMATIC_CLOSE_KEY, AUTO_CLOSE); config.set(CommonConfigurationKeysPublic.FS_DEFAULT_NAME_KEY, defaultFS); config.set(“hbase.zookeeper.quorum”, ConfigUtil.getProperty(CommonConstants.HBASE_CONF, “hbase.host”)); config.set(“hbase.zookeeper.property.clientPort”, ConfigUtil.getProperty(CommonConstants.HBASE_CONF, “hbase.port”)); config.set(“hbase.client.retries.number”, Integer.toString(0)); config.set(“zookeeper.session.timeout”, Integer.toString(6000)); config.set(“zookeeper.recovery.retry”, Integer.toString(0)); config.set(“hbase.master”, “gauravt-namenode.pbi.global.pvt:60000”); config.set(“zookeeper.znode.parent”, “/hbase-secure”); config.set(“hbase.rpc.engine”, “org.apache.hadoop.hbase.ipc.SecureRpcEngine”); config.set(“hbase.security.authentication”, […]

使用Java连接到远程HBase服务

我有一个小示例代码，我尝试建立与远程HBase实体的连接。 代码在没有安装HBase的Windows机器上运行，我尝试连接到安装并运行它的远程Ubuntu服务器。 以下代码段中的IP当然只是一个占位符。 代码如下： public static void main(String[] args) { Configuration conf = HBaseConfiguration.create(); HBaseAdmin admin = null; String ip = “10.10.10.10”; String port = “2181”; conf.set(“hbase.zookeeper.quorum”, ip); conf.set(“hbase.zookeeper.property.clientPort”, port); try { admin = new HBaseAdmin(conf); boolean bool = admin.tableExists(“sensor_data”); System.out.println(“Table exists? ” + bool); } catch (IOException e) { e.printStackTrace(); } } 但由于某种原因，我收到此错误： org.apache.hadoop.hbase.DoNotRetryIOException: […]

如何在OpenTSDB中插入数据（时间序列数据库）

我是OpenTSDB的新手。 我以某种方式设法安装和配置OpenTSDB，但我不知道如何从客户端将数据放入OpenTSDB。 你们有人可以帮助我吗？

连接并坚持使用HBase

我只是尝试使用java客户端连接到hbase，它是cloudera-vm的一部分。 （192.168.56.102是vm的inet ip） 我使用虚拟盒与主机网络设置。 所以我可以访问hbase master的webUI @ http://192.168.56.102:60010/master.jsp 我的java客户端（在vm本身运行良好）也建立了与192.168.56.102:2181的连接 但是当它调用getMaster我得到连接被拒绝时看到log： 11/09/14 11:19:30 INFO zookeeper.ZooKeeper: Initiating client connection, connectString=192.168.56.102:2181 sessionTimeout=180000 watcher=hconnection 11/09/14 11:19:30 INFO zookeeper.ClientCnxn: Opening socket connection to server /192.168.56.102:2181 11/09/14 11:19:30 INFO zookeeper.ClientCnxn: Socket connection established to cloudera-vm/192.168.56.102:2181, initiating session 11/09/14 11:19:30 INFO zookeeper.ClientCnxn: Session establishment complete on server cloudera-vm/192.168.56.102:2181, sessionid = 0x13267157f930009, negotiated […]

从System读取文本文件到Hbase MapReduce

我需要将文本文件中的数据加载到Map Reduce，我很多天都很乖，但我没有找到适合我工作的解决方案。 是否有任何方法或类从系统读取text / csv文件并将数据存储到HBASE表中。 对我来说真的非常紧急，任何人都可以帮助我了解MapReduce F / w。

Phoenix不会正确显示负整数值

我正在创建一个值为整数-17678的HBASE表。 但是当我从pheonix中检索它时，它给了我一个不同的正值。 RowKey是一个复合rowkey，rowkey没有问题。 Hbase插入： public class test { public static void main(String args[]) { Configuration config = HBaseConfiguration.create(); Connection connection = ConnectionFactory.createConnection(config); Table table = connection.getTable(TableName.valueOf(“TEST”)); Integer i=-17678; try { Put p = new Put(Bytes.toBytes(“rowkey”)); p.addColumn(Bytes.toBytes(“test”),Bytes.toBytes(“test”),Bytes.toBytes(i)); table.put(p); } finally { table.close(); connection.close(); } } } 凤凰检索： 从TEST中选择CAST（“Value”AS INTEGER）; +——————————————+ | TO_INTEGER(test.”Value”) | +——————————————+ | 2147465970 […]

hbase api – 按行ID列表获取数据行信息

是否可以通过hbase java API按行ID列表获取hbase数据记录？ 例如，我有一个已知的hbase行id列表： mykey1：myhash1，mykey1：myhash2，mykey1：myhash3，mykey2：myhash5，… 我希望单独调用hbase所有相关的列单元格信息。 我对hbase很新，我不知道这是否支持API。 API伪代码： GetById(String tableName, List rowIds); 那样的东西？ 我可以使用Get(byte[] rowName)从单行检索信息，但是当我有rowId列表时，我需要多次执行get动作，这会导致建立连接并在每次完成时关闭它。 谢谢