spark sql hive 写入hbase

将 Spark SQL 或 Hive 的数据写入 HBase 可以通过两种方式实现：使用 HBase API 或使用 HBase Connector。

1. 使用 HBase API：通过在 Spark 或 Hive 中编写 Java 代码，使用 HBase API 将数据写入 HBase。这种方法需要较多的编程工作，但可以使用 HBase 的高级功能。

2. 使用 HBase Connector：使用 Spark 或 Hive 的 HBase Connector，可以方便地将数据写入 HBase。这种方法不需要编写 Java 代码，但可能会受到 HBase Connector 的限制。

具体使用方法可以参考以下代码示例：

1. 使用 HBase API：

import org.apache.hadoop.hbase.client.{HBaseAdmin,HTable,Put}
import org.apache.hadoop.hbase.{HBaseConfiguration,HTableDescriptor,HColumnDescriptor}
import org.apache.hadoop.hbase.util.Bytes

val conf = HBaseConfiguration.create()
val admin = new HBaseAdmin(conf)

// 创建表
val tableDescriptor = new HTableDescriptor(tableName)
tableDescriptor.addFamily(new HColumnDescriptor(columnFamily))
admin.createTable(tableDescriptor)

// 写入数据
val table = new HTable(conf, tableName)
val put = new Put(Bytes.toBytes(rowKey))
put.add(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(value))
table.put(put)

2. 使用 HBase Connector：

// 使用 Spark SQL 写入 HBase
spark.sql("CREATE TABLE hbase_table USING org.apache.spark.sql.execution.datasources.hbase OPTIONS ('table' 'table_name', 'family' 'column_family', 'rowkey' 'row_key_column')")
df.write.format("org.apache.spark.sql.execution.datasources.hbase").save()

// 使用 Hive 写入 HBase
INSERT INTO TABLE hbase_table SELECT * FROM hive_table;