您可以使用HBase的API在一个Hadoop的工作。
以下是在作业中使用HBase API的一些代码片段。
进口
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
这是一个@Override
函数内部在我的代码
private HTable hTable = null;
Configuration hConfig = HBaseConfiguration.create();
hConfig.set(Constants.HBASE_CONFIGURATION_ZOOKEEPER_QUORUM, zkQuorum);
hConfig.set(Constants.HBASE_CONFIGURATION_ZOOKEEPER_CLIENTPORT, zkclientPort);
hTable = new HTable(hConfig, hbCube);
...
hTable.put(subPuts);
显然不是完整的片段,但正确的imports
,并提供正确的价值观你的工作(我只用了一映射器)可以访问HBase API。
希望有所帮助。