- Feb 14, 2013
-
-
Tathagata Das authored
STREAMING-50: Support transform workaround in JavaPairDStream
-
- Feb 13, 2013
-
-
Matei Zaharia authored
Update issue tracker link in contributing guide
-
- Feb 12, 2013
-
-
Patrick Wendell authored
This ports a useful workaround (the `transform` function) to JavaPairDStream. It is necessary to do things like sorting which are not supported yet in the core streaming API.
-
- Feb 11, 2013
-
-
Matei Zaharia authored
SPARK-694: All references to [K, V] in JavaDStreamLike should be changed to [K2, V2]
-
Matei Zaharia authored
SPARK-696: sortByKey should use 'ascending' parameter
-
Patrick Wendell authored
-
Matei Zaharia authored
-
Matei Zaharia authored
to lack of memoization
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Patrick Wendell authored
-
Matei Zaharia authored
Conflicts: core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala core/src/main/scala/spark/scheduler/cluster/StandaloneSchedulerBackend.scala
-
root authored
Also fixes some issues in the rest of the code with detecting workers this way. Conflicts: core/src/main/scala/spark/deploy/master/Master.scala core/src/main/scala/spark/deploy/worker/Worker.scala core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala core/src/main/scala/spark/scheduler/cluster/StandaloneClusterMessage.scala core/src/main/scala/spark/scheduler/cluster/StandaloneSchedulerBackend.scala
-
- Feb 10, 2013
-
-
Matei Zaharia authored
Conflicts: docs/_config.yml
-
Matei Zaharia authored
Conflicts: core/src/main/twirl/spark/deploy/master/index.scala.html core/src/main/twirl/spark/deploy/worker/index.scala.html
-
Matei Zaharia authored
other issues Conflicts: run2.cmd
-
Josh Rosen authored
-
Matei Zaharia authored
Fixed a 404 in 'Tuning Spark' -- missing '.html'
-
Mark Hamstra authored
-
- Feb 09, 2013
-
-
Matei Zaharia authored
add as many fetch requests as we can, subject to maxBytesInFlight
-
Matei Zaharia authored
SPARK-678: Adding an example with an OLAP roll-up
-
Matei Zaharia authored
Add RDD.coalesce, clean up some RDDs, other misc.
-
Stephen Haberman authored
-
Josh Rosen authored
Add commutative requirement for 'reduce' to Python docstring.
-
Stephen Haberman authored
-
Mark Hamstra authored
-
Matei Zaharia authored
Change docs on 'reduce' since the merging of local reduces no longer pre...
-
Stephen Haberman authored
-
Stephen Haberman authored
-
- Feb 08, 2013
-
-
- Feb 07, 2013
-
-
Matei Zaharia authored
SPARK-685 Adding IPYTHON environment variable support for launching pyspark using ...
-
Nick Pentreath authored
-
- Feb 06, 2013
-
-
Mark Hamstra authored
ordering, so the reduce function must also be commutative.
-
- Feb 05, 2013
-
-
Patrick Wendell authored
-
Stephen Haberman authored
Also made sure clearDependencies() was calling super, to ensure the getSplits/getDependencies vars in the RDD base class get cleaned up.
-
Stephen Haberman authored
Also rename r->rdd and remove unneeded extra type info.
-
Stephen Haberman authored
-