- Nov 20, 2012
-
-
Thomas Dudziak authored
-
- Nov 11, 2012
-
-
root authored
-
- Oct 12, 2012
-
-
Matei Zaharia authored
- Added a StorageLevels class for easy access to StorageLevel constants in Java - Added doc comments on Function classes in Java - Updated Accumulator and HadoopWriter docs slightly
-
- Sep 25, 2012
-
-
Matei Zaharia authored
-
- Aug 30, 2012
-
-
Mosharaf Chowdhury authored
-
- Aug 26, 2012
-
-
Josh Rosen authored
-
- Aug 12, 2012
-
-
Matei Zaharia authored
-
- Aug 04, 2012
-
-
Denny authored
-
- Jul 28, 2012
-
-
Imran Rashid authored
-
- Jul 25, 2012
-
-
Josh Rosen authored
-
- Jul 24, 2012
-
-
Josh Rosen authored
- Add override keywords. - Cache RDDs and counts in TC example. - Clean up JavaRDDLike's abstract methods.
-
- Jul 22, 2012
-
-
Josh Rosen authored
- Replace JavaLR example with JavaHdfsLR example. - Use anonymous classes in JavaWordCount; add options. - Remove @Override annotations.
-
- Jul 18, 2012
-
-
Josh Rosen authored
Add distinct() method to RDD. Fix bug in DoubleRDDFunctions.
-
Denny authored
-
Denny authored
-
- Jul 12, 2012
-
-
Imran Rashid authored
-
- Jun 06, 2012
-
-
Matei Zaharia authored
-
- Feb 09, 2012
-
-
haoyuan authored
-
- Jan 31, 2012
-
-
Matei Zaharia authored
-
- Dec 01, 2011
-
-
Matei Zaharia authored
(you can no longer iterate over a Source multiple times).
-
Edison Tung authored
-
Edison Tung authored
-
- Nov 21, 2011
-
-
Edison Tung authored
LocalKMeans runs locally with a randomly generated dataset. SparkLocalKMeans takes an input file and runs KMeans on it.
-
- Nov 13, 2011
-
-
Ankur Dave authored
When a task throws an exception, the Spark executor previously just logged it to a local file on the slave and exited. This commit causes Spark to also report the exception back to the driver using a Mesos status update, so the user doesn't have to look through a log file on the slave. Here's what the reporting currently looks like: # ./run spark.examples.ExceptionHandlingTest master@203.0.113.1:5050 [...] 11/10/26 21:04:13 INFO spark.SimpleJob: Lost TID 1 (task 0:1) 11/10/26 21:04:13 INFO spark.SimpleJob: Loss was due to java.lang.Exception: Testing exception handling [...] 11/10/26 21:04:16 INFO spark.SparkContext: Job finished in 5.988547328 s
-
- Nov 01, 2011
-
-
Matei Zaharia authored
-
- Aug 02, 2011
-
-
Ismael Juma authored
Note that we use scala.Serializable introduced in Scala 2.9 instead of java.io.Serializable. Also, case classes inherit from scala.Serializable by default.
-
- May 26, 2011
-
-
Ismael Juma authored
tabulate used if indexed used by function and fill otherwise.
-
Ismael Juma authored
-
- Feb 27, 2011
-
-
Matei Zaharia authored
-
- Feb 09, 2011
-
-
Mosharaf Chowdhury authored
-
- Feb 02, 2011
-
-
Matei Zaharia authored
-
- Feb 01, 2011
-
-
Matei Zaharia authored
-