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

Question

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

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

您可以使用以下内容：

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

Answer 2

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