Big Data, Spark, Event Hub, Scala, Azure.
|Map() <...Shortened...> Code: // Body is binary, so we cast it to string to see the actual content of the message val messages = incomingStream.selectExpr("cast (body as string) AS Content") messages.writeStream.outputMode("append").format("console").option("truncate",