Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
Smart Thermostat AWS Spark - Part Spark retrieve scenario information
//spark settings
val sparkconf = new SparkConf().setAppName("tempscore")
val sc = new SparkContext(sparkconf)
//get scenario information from husedscenario table
val confmrscen = HBaseConfiguration.create()
val rowval = args(0).getBytes() //used scenario key is input
val getscenvals = new Get(rowval)
val tablescenvals = new HTable(confmrscen,"husedscenario")
val resgetscenvals = tablescenvals.get(getscenvals)
val valscenariokey = resgetscenvals.getValue("fd".getBytes(), "scenariokey".getBytes())
val valsettemp : Int = Bytes.toString(resgetscenvals.getValue("fd".getBytes(), "settemp".getBytes())).toInt
val valrevepoch : Long = Bytes.toString(rowval).substring(9,19).toLong
val valmaxrevepoch : Long = valrevepoch - (60L*60L) //limit to one hour after scenario started
tablescenvals.close()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment