Skip to content
Snippets Groups Projects
Commit 6a6c1fc5 authored by Bryan Cutler's avatar Bryan Cutler Committed by Davies Liu
Browse files

[SPARK-11713] [PYSPARK] [STREAMING] Initial RDD updateStateByKey for PySpark 

Adding ability to define an initial state RDD for use with updateStateByKey PySpark.  Added unit test and changed stateful_network_wordcount example to use initial RDD.

Author: Bryan Cutler <bjcutler@us.ibm.com>

Closes #10082 from BryanCutler/initial-rdd-updateStateByKey-SPARK-11713.
parent 4a46b885
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment