Last active
May 17, 2018 12:25
-
-
Save gupta-himanshu/a7207fa082e9b694cc6c6e74e9c97dad to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
val sparkConf = new SparkConf().setAppName("RecoverableNetworkWordCount") | |
// Create the context with a 1 second batch size | |
val ssc = new StreamingContext(sparkConf, Seconds(1)) | |
ssc.checkpoint("/path/to/checkpoint") |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment