- Jan 01, 2014
-
-
Matei Zaharia authored
-
Matei Zaharia authored
Also replaced SparkConf.getOrElse with just a "get" that takes a default value, and added getInt, getLong, etc to make code that uses this simpler later on.
-
- Dec 30, 2013
-
-
Matei Zaharia authored
-
- Dec 29, 2013
-
-
Matei Zaharia authored
-
Matei Zaharia authored
tests so we don't get the test spark.conf on the classpath.
-
Matei Zaharia authored
-
Matei Zaharia authored
The test in context.py created two different instances of the SparkContext class by copying "globals", so that some tests can have a global "sc" object and others can try initializing their own contexts. This led to two JVM gateways being created since SparkConf also looked at pyspark.context.SparkContext to get the JVM.
-
Matei Zaharia authored
-
- Dec 28, 2013
-
-
Matei Zaharia authored
-
Tor Myklebust authored
-
- Dec 25, 2013
-
-
Tor Myklebust authored
-
Tor Myklebust authored
-
- Dec 24, 2013
-
-
Tor Myklebust authored
-
Tor Myklebust authored
-
Andrew Ash authored
-
Tathagata Das authored
-
Tor Myklebust authored
-
Tor Myklebust authored
-
- Dec 22, 2013
-
-
Tor Myklebust authored
-
- Dec 21, 2013
-
-
Tor Myklebust authored
-
- Dec 20, 2013
-
-
Tor Myklebust authored
-
Tor Myklebust authored
-
Tor Myklebust authored
-
Tor Myklebust authored
-
Tor Myklebust authored
-
Tor Myklebust authored
-
- Dec 19, 2013
-
-
Tor Myklebust authored
-
Tor Myklebust authored
-
Shivaram Venkataraman authored
Change the implementation to use runJob instead of PartitionPruningRDD. Also update the unit tests and the python take implementation to use the new interface.
-
Nick Pentreath authored
-
Tor Myklebust authored
Incorporate most of Josh's style suggestions. I don't want to deal with the type and length checking errors until we've got at least one working stub that we're all happy with.
-
Tor Myklebust authored
-
Tor Myklebust authored
-
- Dec 18, 2013
-
-
Shivaram Venkataraman authored
Also remove takePartition from PythonRDD and use collectPartition in rdd.py.
-
- Dec 09, 2013
-
-
Patrick Wendell authored
-
- Nov 29, 2013
-
-
Josh Rosen authored
Fixes SPARK-970.
-
- Nov 26, 2013
-
-
Josh Rosen authored
-
- Nov 10, 2013
-
-
Josh Rosen authored
-
Josh Rosen authored
-
Josh Rosen authored
For now, this only adds MarshalSerializer, but it lays the groundwork for other supporting custom serializers. Many of these mechanisms can also be used to support deserialization of different data formats sent by Java, such as data encoded by MsgPack. This also fixes a bug in SparkContext.union().
-