Big Data, Spark, Event Hub, Scala, Azure.
EventHubClient.createFromConnectionStringSync(connStr.toString()) def sendEvent(message: String) = { val messageData = new EventData(message.getBytes("UTF-8")) eventHubClient.send(messageData) System.out.println("Sent event: " + message + "\n") } import twitter4j._ import twitter4j.TwitterFactory