Here is a code snippet where the df5 dataframe successfully prints json data but isStream is false and it's deprecated in Spark 2.2.0. I attempted another approach in the last two lines of code to handle this, however, it fails to read json correctly. Any suggestions on how to fix this issue?
val unionStreams = ssc.union(kinesisStreams)
unionStreams.foreachRDD ((rdd: RDD[Array[Byte]], time: Time) => {
val rowRDD = rdd.map(jstr => new String(jstr))
val schema = StructType(StructField("clientTime",StringType,nullable= true) :: StructField("clientIPAddress", StringType,nullable = true) :: Nil)
val df5 = sqlContext.read.schema(schema).json(rowRDD)
println(df5.isStreaming)
val df6 = spark.readStream.schema(schema).json(rdd.toString())
println(df6.isStreaming) )}