Simple wordcount example with apahce spark structured streaming

Usage

Data

• from netcat utility on linux terminal.

nc -l 9999

Run spark job with spark-submit

spark-submit spark-Application.py localhost 9999