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

Popular posts from this blog

Qt4: how to send QString inside a struct via QSharedMemory -

node.js - NodeJS remote terminal to Dropbear OpenWRT-Server -

node.js - On Gitbash - Bower : ENOGIT git is not installed or not in the PATH -