使用 Phoenix-Spark 添加 HBase 时间戳 API

Question

如何使用类似于 HBase 的 Phoenix-Spark 添加 HBase 时间戳 API:

Put(rowkey, timestamp.getMillis)

这是我的代码：

val rdd = processedRdd.map(r => Row.fromSeq(r))
val dataframe = sqlContext.createDataFrame(rdd, schema)
dataframe.save("org.apache.phoenix.spark", SaveMode.Overwrite,
    Map("table" -> HTABLE, "zkUrl" -> zkQuorum))

Answer 1

Phoenix 目前不支持此功能。也许，您需要使用 HBase api 而不是 Phoenix。

Answer 2

您可以使用以下内容：

dataframe.write.format("org.apache.phoenix.spark").mode("overwrite").option("table", "HTable").option("zkUrl", "xxxx:0000").save()

使用 Phoenix-Spark 添加 HBase 时间戳 API

add HBase Timestamp using Phoenix-Spark API

hbase

phoenix

apache-spark