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

qt - Using float or double for own QML classes -

Create Outlook appointment via C# .Net -

ios - Swift Array Resetting Itself -