apache spark - Databricks Twitter streaming analysis scala -


hi trying run databricks twitter_classifier github code @ local system.

but these below code lines in examineandtrain.scala, getting encoder error.

val texts = sqlcontext.sql("select text tweettable").map(_.tostring) // cache vectors rdd since used kmeans iterations. val vectors = texts.map(utils.featurize).cache() 

after using

import sqlcontext.implicits._ val texts = sqlcontext.sql("select text tweettable").map(_.tostring) // cache vectors rdd since used kmeans iterations. val vectors = texts.map(utils.featurize).cache()  

encoder error mapping text-> string resolved while mapping string -> vector still showing. here featurize() function takes string , returns vector

note - using spark version 1.5.2

thanks.


Comments

Popular posts from this blog

aws api gateway - SerializationException in posting new Records via Dynamodb Proxy Service in API -

asp.net - Problems sending emails from forum -