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
Post a Comment