用spark抽取hive数据到HBASE

要将Hive数据抽取到HBase中，可以使用Spark的Hive和HBase的集成功能。以下是一个简单的流程：

1. 在Hive中创建一个表，该表的数据将被抽取到HBase中：

CREATE TABLE hive_table (
  id INT,
  name STRING,
  age INT
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
STORED AS TEXTFILE;

2. 在HBase中创建一个表，该表将用来存储从Hive表中抽取的数据：

create 'hbase_table', 'cf'

3. 在Spark应用程序中，使用Spark的HiveContext加载Hive表：

val hiveContext = new HiveContext(sparkContext)
val hiveTable = hiveContext.sql("SELECT * FROM hive_table")

4. 将Hive表中的数据转换为HBase表中的数据：

val hbaseTable = hiveTable.map(row => {
  val id = row.getInt(0)
  val name = row.getString(1)
  val age = row.getInt(2)
  val put = new Put(Bytes.toBytes(id))
  put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("name"), Bytes.toBytes(name))
  put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("age"), Bytes.toBytes(age))
  (new ImmutableBytesWritable(Bytes.toBytes(id)), put)
})

5. 将转换后的数据保存到HBase中：

val conf = HBaseConfiguration.create()
hbaseTable.saveAsNewAPIHadoopDataset(conf)

这样，就可以将Hive表中的数据抽取到HBase中了。需要注意的是，需要引入相关的依赖和配置文件，例如Hive和HBase的JAR包、Hive和HBase的配置文件等。