.. |
api/java
|
Add JavaRDDLike.keyBy.
|
2013-01-08 09:57:45 -06:00 |
broadcast
|
Search for a non-loopback address in Utils.getLocalIpAddress
|
2012-12-08 00:33:11 -08:00 |
deploy
|
Added an optional format parameter for individual job queries and optimized the jobId query
|
2013-01-11 15:01:43 -05:00 |
executor
|
Extra whitespace in ExecutorExitCode
|
2012-12-13 18:39:23 -08:00 |
network
|
Modified Patch according to comments
|
2013-01-10 20:09:55 +08:00 |
partial
|
Make more stuff private[spark]
|
2012-10-02 22:28:55 -07:00 |
rdd
|
SPARK-635: Pass a TaskContext object to compute() interface and use
|
2012-12-13 16:41:15 -08:00 |
scheduler
|
Code style
|
2013-01-08 22:29:57 -08:00 |
serializer
|
More doc updates, and moved Serializer to a subpackage.
|
2012-10-12 18:19:21 -07:00 |
storage
|
Let the slave notify the master block removal.
|
2012-12-20 01:37:09 -08:00 |
util
|
Moved BlockManager's IdGenerator into BlockManager object. Removed some
|
2012-12-19 15:27:23 -08:00 |
Accumulators.scala
|
Add Accumulable.setValue for easier use in Java
|
2013-01-07 16:50:23 -05:00 |
Aggregator.scala
|
Remove mapSideCombine field from Aggregator.
|
2012-10-13 14:59:20 -07:00 |
BlockStoreShuffleFetcher.scala
|
Change ShuffleFetcher to return an Iterator.
|
2012-10-13 14:59:20 -07:00 |
Cache.scala
|
Make classes package private
|
2012-10-02 19:00:19 -07:00 |
CacheTracker.scala
|
Remove some dead comments
|
2013-01-01 08:07:44 -08:00 |
ClosureCleaner.scala
|
Make classes package private
|
2012-10-02 19:00:19 -07:00 |
DaemonThreadFactory.scala
|
Ported performance and FT improvements from latest streaming work
|
2012-09-12 14:54:40 -07:00 |
Dependency.scala
|
Merge remote-tracking branch 'JoshRosen/shuffle_refactoring' into dev
|
2012-10-23 22:01:45 -07:00 |
DoubleRDDFunctions.scala
|
Added documentation to all the *RDDFunction classes, and moved them into
|
2012-10-09 18:38:36 -07:00 |
FetchFailedException.scala
|
Make classes package private
|
2012-10-02 19:00:19 -07:00 |
HadoopWriter.scala
|
Support for Hadoop 2 distributions such as cdh4
|
2012-10-18 16:08:54 -07:00 |
HttpFileServer.scala
|
Make classes package private
|
2012-10-02 19:00:19 -07:00 |
HttpServer.scala
|
Make classes package private
|
2012-10-02 19:00:19 -07:00 |
JavaSerializer.scala
|
More doc updates, and moved Serializer to a subpackage.
|
2012-10-12 18:19:21 -07:00 |
KryoSerializer.scala
|
Remove the call to close input stream in Kryo serializer.
|
2012-12-21 15:49:33 -08:00 |
Logging.scala
|
Scaladoc documentation for some core Spark functionality
|
2012-10-04 22:59:36 -07:00 |
MapOutputTracker.scala
|
Add try-finally to handle MapOutputTracker timeouts.
|
2012-12-13 21:53:30 -08:00 |
package.scala
|
Scaladoc documentation for some core Spark functionality
|
2012-10-04 22:59:36 -07:00 |
PairRDDFunctions.scala
|
Add PairRDDFunctions.keys and values.
|
2013-01-05 12:04:01 -06:00 |
ParallelCollection.scala
|
SPARK-635: Pass a TaskContext object to compute() interface and use that
|
2012-12-13 15:41:53 -08:00 |
Partitioner.scala
|
Raise exception when hashing Java arrays (SPARK-597)
|
2012-12-31 20:20:11 -08:00 |
RDD.scala
|
Merge branch 'master' into tupleBy
|
2013-01-08 09:10:10 -06:00 |
SequenceFileRDDFunctions.scala
|
Update Hadoop dependency to 1.0.3 as 0.20 has Sun specific dependencies. Also
|
2013-01-07 15:57:33 -08:00 |
SerializableWritable.scala
|
Fix issue #65: Change @serializable to extends Serializable in 2.9 branch
|
2011-08-02 10:16:33 +01:00 |
ShuffleFetcher.scala
|
Change ShuffleFetcher to return an Iterator.
|
2012-10-13 14:59:20 -07:00 |
SizeEstimator.scala
|
Remove dependencies on sun jvm classes. Instead use reflection to infer
|
2013-01-07 15:57:18 -08:00 |
SoftReferenceCache.scala
|
Make classes package private
|
2012-10-02 19:00:19 -07:00 |
SparkContext.scala
|
Fix Accumulators in Java, and add a test for them
|
2013-01-05 20:55:17 -05:00 |
SparkEnv.scala
|
Added the ability in block manager to remove blocks.
|
2012-12-13 00:04:42 -08:00 |
SparkException.scala
|
Upgraded to Akka 2 and fixed test execution (which was still parallel
|
2012-06-28 23:51:28 -07:00 |
Split.scala
|
Various code style fixes, mostly from IntelliJ IDEA
|
2012-06-29 18:47:12 -07:00 |
TaskContext.scala
|
SPARK-635: Pass a TaskContext object to compute() interface and use
|
2012-12-13 16:41:15 -08:00 |
TaskEndReason.scala
|
Stylistic changes and Public Accumulable and Broadcast
|
2012-10-02 19:28:37 -07:00 |
TaskState.scala
|
Make classes package private
|
2012-10-02 19:00:19 -07:00 |
Utils.scala
|
Change Utils.fetchFile() warning to SparkException.
|
2012-12-28 17:37:13 -08:00 |