Hi everyone, I already found a solution. I was sending just
strings to the angular controller (not a json object). In the controller an angular.Foreach is used to iterate the
incoming value “newValue”. This
function iterates both objects and arrays. What I sent was interpreted as
an element of a strings array and not as Json object, i.e. {"value":"-2.5119123","loc":{"lat":53.3,"lon":7.125}} In the first iteration the value evaluated
was: "value":"-2.5119123" And in the second: "loc":{"lat":53.3,"lon":7.125} I just modified the scala code in order to
send the whole Array[String]: %spark2
import scala.util.parsing.json.JSONObject
import org.apache.spark.sql._
import org.json4s._
import org.json4s.JsonDSL._
import org.json4s.jackson.JsonMethods._
val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
val hadoopConf = sc.hadoopConfiguration
hadoopConf.set("mapreduce.input.fileinputformat.input.dir.recursive", "true")
val COSMODE_Wind = sqlContext.sql("SELECT lat0, long0, value FROM dev_sdsp.cosmode_single_level_elements_v_10m limit 100")
case class Loc(lat: Double, lon: Double)
case class Wind(value: String, loc: Loc)
val dataPoints = COSMODE_Wind.map{s => Wind(s.getDouble(2).toString, Loc( s.getDouble(0), s.getDouble(1)))}
val dataPointsJson = dataPoints.toJSON.take(100)
z.angularBind("locations", dataPointsJson)
Then the angular.Foreach iterate the whole “row” {"value":"-2.5119123","loc":{"lat":53.3,"lon":7.125}} Wich can be converted to a json object
using javascript Finally, the values are accessible using dot
notation. Here the Angular snippet: var el = angular.element($('#map').parent('.ng-scope'));
angular.element(el).ready(function() {
window.locationWatcher = el.scope().compiledScope.$watch('locations', function(newValue, oldValue) {
// geoMarkers.clearLayers(); -- if you want to only show new data clear the layer first
console.log("new value: " + newValue);
angular.forEach(newValue, function(wind) {
try { JSON.parse(wind); } catch(error) { alert(error); }
windJSON = JSON.parse(wind)
var marker = L.marker([windJSON.loc.lat, windJSON.loc.lon]).bindPopup(windJSON.value).addTo(geoMarkers);
});
})
});
Hope ths helps someone.
... View more
