Hi,
In that case, you can try the following.
val joinRDD = kafkaStream.transform( streamRDD => {
val ids = streamRDD.map(_._2).collect();
ids.map(userId => ctable.select("user_name").where("userid = ?",
userId).toArray(0).get[String](0))
// better create a query which checks for all those ids
Hi there,
I think I have a basic question, but I'm sort of stuck with figuring out
how to approach it, and I thought someone could point me to the right
direction.
I'd like pull some data from Cassandra based on values received from an
input stream. Something like
val ctable = ssc.cassa
