Use DataFrames and SQL to count words in UTF8 encoded, '\n' delimited text received from the
network every second.
Usage: SqlNetworkWordCount <hostname> <port>
<hostname> and <port> describe the TCP server that Spark Streaming would connect to receive data.
To run this on your local machine, you need to first run a Netcat server
$ nc -lk 9999
and then run the example
$ bin/run-example org.apache.spark.examples.streaming.SqlNetworkWordCount localhost 9999
Use DataFrames and SQL to count words in UTF8 encoded, '\n' delimited text received from the network every second.
Usage: SqlNetworkWordCount <hostname> <port> <hostname> and <port> describe the TCP server that Spark Streaming would connect to receive data.
To run this on your local machine, you need to first run a Netcat server
$ nc -lk 9999and then run the example$ bin/run-example org.apache.spark.examples.streaming.SqlNetworkWordCount localhost 9999