spark-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Deepu Raj <>
Subject Spark Streaming Cassandra Transformation
Date Mon, 15 May 2017 06:25:02 GMT
Hi Team,

1. Can someone please guide on  how to change the following transformation  
change for the below data in Spark 2.0?

{"name":"Michael", "age":30, "state":AZ, "Job": SoftwareDev}
{"name":"Andy", "age":30,  "state":WA, "Job": Mana}
{"name":"Justin", "age":19, , "state":VIC, "Job": DBAdmin}

KafkaUtils.createStream[String, String, StringDecoder, StringDecoder](
ssc, kafkaParams, topicMap, StorageLevel.MEMORY_ONLY)
.map{ case (_,json) =>  

2. What is the best way to do this push JSON into Cassandra without using  

Deepu Raj
Using Opera's mail client:

To unsubscribe e-mail:

View raw message