ArrayOutOfBoundException when iterating through a data frame in spark SQL -


i have data set of called people.json

{"name":"michael"} {"name":"andy", "age":30} {"name":"justin", "age":19}

the following code gives me arrayoutofboundsexception.

  import org.apache.spark.sql.sparksession    val sparksession = sparksession.builder     .master("local")     .appname("my-spark-app")     .config("spark.some.config.option", "config-value")     .getorcreate()    val peopledf = sparksession.sparkcontext.     textfile("c:/users/desktop/spark/people.json").     map(_.split(",")).     map(attributes => person(attributes(0),attributes(1).trim.toint)).     todf()    peopledf.createorreplacetempview("person")    val teenagersdf = sparksession.sql("select name, age person")    teenagersdf.show()

looks trying work through empty dataframe. can tell me why empty?

when have valid json file, should use sqlcontext read json file dataframe. 

 import org.apache.spark.sql.sparksession    val sparksession = sparksession.builder     .master("local")     .appname("my-spark-app")     .config("spark.some.config.option", "config-value")     .getorcreate()    val peopledf = sparksession.sqlcontext.read.json("c:/users/desktop/spark/people.json")    peopledf.createorreplacetempview("person")    val teenagersdf = sparksession.sql("select name, age person")    teenagersdf.show()

this should work


Comments

Post a Comment

Popular posts from this blog

javascript - Create a stacked percentage column -

i have collection of data : var data = [ {"p301a":"10","p301b":"7","p301c":"7","p301d":"3","p301e":"8","p301f":"8","p301g":"8","p301h":"8","p301i":"8","p301j":"8","p301k":"8","p301l":"8","p301m":"8","p301n":"8","p301o":"8","age":"31-40 years","profesion":"2","position":"2"}, {"p301a":"5","p301b":"4","p301c":"4","p301d":"4","p301e":"4","p301f":"4","p301g":"4","p301h":"4","p301i":"4","p301j":"4","p301k":"4...
Read more

vue.js - Create hooks for automated testing -

Image
qa guys complained can't automate frontend testing. because our html looks same outside. lazy hack did this <template> <div :role="$options.name"> ... </div> </template> <script> export default { name: 'vmcomponentname' } </script> which takes name script , applies html. in browser get: <div role="vmcomponentname"> ... </div> line :role="$options.name" goes in every component. is there dry er solutions? please share. additional details i'll explain in details looking for. imagine have vmusercreate form creates user. test case can create user . to automatically test without role, have use following selector: .wrapper > .wrapper > .wrapper > .submit-button the test extremely brittle (will break lot). if use roles can use [role="vmusercreateform"] .submit-button selector. many folds less brittle. so basically, i'm ...
Read more

Optimising Firebase database by automatically overwriting data -

in firebase app have following structure: posts latest all users can write posts > latest . want limit entries 20 posts save space in database. , posts beyond 20 unnecessary never shown on homepage. how can limit posts 20, when user writes posts > latest posts @ end drop off (be deleted) automatically? this sample should you. you need : const max_log_count = 20; exports.removeold = functions.database.ref('/posts/latest/{postid}').oncreate(event => { const parentref = event.data.ref.parent; return parentref.once('value').then(snapshot => { if (snapshot.numchildren() >= max_log_count) { let childcount = 0; const updates = {}; snapshot.foreach(function(child) { if (++childcount <= snapshot.numchildren() - max_log_count) { updates[child.key] = null; } }); // update parent. removes children. ...
Read more