Skip to content

spark updateStateByKey

Latest
Compare
Choose a tag to compare
@herywang herywang released this 09 Feb 06:37
· 8 commits to master since this release

Spark Streaming updateStateByKey transformation function.

Please ensure:

mkdir /word_count_checkpoint directory in your HDFS file system.
start nc -lk 9999 in your terminal.

And then run this application.

Please ignore the source code, It's just my study note.