Skip to content

GitLab

Explore

Sign in

Primary navigation

Project

S

spark
- Activity
- Members
- Labels
- Issues
- Issue boards
- Milestones
- Wiki
- Releases
- Model registry
- Environments
- Incidents

Snippets Groups Projects

490f056c

Commit 490f056c authored 12 years ago by Matei Zaharia

Downloads
- Patches
- Plain Diff

Allow passing sparkHome and JARs to StreamingContext constructor

Also warns if spark.cleaner.ttl is not set in the version where you pass
your own SparkContext.

parent 568bdaf8

No related branches found

No related tags found

Loading

Changes 8

Hide whitespace changes

Inline Side-by-side

Showing

core/src/main/scala/spark/SparkContext.scala 1 addition, 1 deletion

core/src/main/scala/spark/SparkContext.scala
core/src/main/scala/spark/api/java/JavaSparkContext.scala 2 additions, 2 deletions

core/src/main/scala/spark/api/java/JavaSparkContext.scala
docs/scala-programming-guide.md 2 additions, 2 deletions

docs/scala-programming-guide.md
docs/streaming-programming-guide.md 3 additions, 7 deletions

docs/streaming-programming-guide.md
streaming/src/main/scala/spark/streaming/Checkpoint.scala 1 addition, 0 deletions

streaming/src/main/scala/spark/streaming/Checkpoint.scala
streaming/src/main/scala/spark/streaming/StreamingContext.scala 30 additions, 10 deletions

...ing/src/main/scala/spark/streaming/StreamingContext.scala
streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala 36 additions, 0 deletions

...scala/spark/streaming/api/java/JavaStreamingContext.scala
streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala 1 addition, 0 deletions

...ain/scala/spark/streaming/dstream/KafkaInputDStream.scala

with 76 additions and 22 deletions

Loading

0% Loading or .

You are about to add 0 people to the discussion. Proceed with caution.

Finish editing this message first!

Please register or sign in to comment