add HBase Timestamp using Phoenix-Spark API -
how add hbase timestamp using phoenix-spark similiar hbase api:
put(rowkey, timestamp.getmillis)
this code:
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))
this feature not supported in phoenix. maybe, need use hbase api instead of phoenix.
Comments
Post a Comment