Skip to content

Instantly share code, notes, and snippets.

View lnicalo's full-sized avatar

Luis F. Nicolas-Alonso lnicalo

  • Biomedical Engineering Group, University of Valladolid
  • Valladolid, Spain
View GitHub Profile
How would you do the same in python with pyspark?
I have written this piece of code but it does not work
keyConv = "org.apache.spark.examples.pythonconverters.ImmutableBytesWritableToStringConverter"
valueConv = "org.apache.spark.examples.pythonconverters.HBaseResultToStringConverter"
data_conf = {
"hbase.mapreduce.inputtable": "raw_signals",
"hbase.mapreduce.scan.columns": "family1:col1 family2:col2",