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