如何使用类似Phoenix-Spark的HBase时间戳添加到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))
Phoenix当前不支持此功能。也许您需要使用HBase api而不是Phoenix。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句