Structured Streaming in Spark

Prerequisites for Using Structured Streaming in Spark
To deploy a structured streaming application in Spark, you must create a MapR Streams topic and install a Kafka client on all nodes in your cluster.

Using Structured Streaming to Create a Word Count Application
The example in this section creates a dataset representing a stream of input lines from Kafka and prints out a running word count of the input lines to the console.

Writing a Structured Spark Stream to HPE Ezmeral Data Fabric Database JSON Table
The example in this section writes a structured stream in Spark to HPE Ezmeral Data Fabric Database JSON table.

Writing a Spark Stream Word Count Application to HPE Ezmeral Data Fabric Database
The example in this section writes a Spark stream word count application to HPE Ezmeral Data Fabric Database.

Structured Streaming in Spark

Related Links