Big Data, Spark, Event Hub, Scala, Azure.
to string, because we have written tweets in string format on the Event Hubs side. It is hard for humans to read byte arrays: val messages = incomingStream.selectExpr(“cast (body as string) AS Content”) messages.writeStream.outputMode(“append”).format(“console”).option(“truncate”,