aboutsummaryrefslogtreecommitdiff
path: root/core
Commit message (Expand)AuthorAgeFilesLines
* Merge pull request #370 from tdas/streamingTathagata Das2013-01-131-3/+3
|\
| * Added documentation for PairDStreamFunctions.Tathagata Das2013-01-131-3/+3
* | switch to uppercase constantsRyan LeCompte2013-01-131-4/+4
* | more code cleanupRyan LeCompte2013-01-131-31/+32
* | add commentRyan LeCompte2013-01-121-0/+1
* | add one extra testRyan LeCompte2013-01-121-0/+1
* | correct test paramsRyan LeCompte2013-01-121-2/+2
* | add unit testRyan LeCompte2013-01-112-1/+23
* | add missing returnRyan LeCompte2013-01-111-0/+1
* | attempt to sleep for more accurate time period, minor cleanupRyan LeCompte2013-01-111-8/+11
* | Merge pull request #350 from tdas/streamingMatei Zaharia2013-01-0742-307/+1535
|\|
| * Changed locations for unit test logs.Tathagata Das2013-01-071-2/+2
| * Added better docs for RDDCheckpointDataTathagata Das2013-01-072-1/+13
| * Renamed examples and added documentation.Tathagata Das2013-01-071-2/+2
| * Changed cleanup to clearOldValues for TimeStampedHashMap and TimeStampedHashSet.Tathagata Das2013-01-077-12/+18
| * Fixed compilation bug in RDDSuite created during merge for mesos/master.Tathagata Das2013-01-011-3/+3
| * Merge branch 'mesos' into dev-mergeTathagata Das2013-01-0110-47/+187
| |\
| | * Merge pull request #349 from woggling/cache-finallyMatei Zaharia2013-01-012-11/+28
| | |\
| | | * Remove some dead commentsCharles Reiss2013-01-011-6/+0
| | | * Test with exception while computing cached RDD.Charles Reiss2013-01-011-0/+23
| | | * Mark key as not loading in CacheTracker even when compute() failsCharles Reiss2013-01-011-10/+10
| | * | Raise exception when hashing Java arrays (SPARK-597)Josh Rosen2012-12-314-0/+58
| | |/
| * | Refactored a whole lot to push all DStreams into the spark.streaming.dstream ...Tathagata Das2012-12-301-0/+1
| * | Improved jekyll and scala docs. Made many classes and method private to remov...Tathagata Das2012-12-291-1/+0
| * | Modifications to make sure LocalScheduler terminate cleanly without errors wh...Tathagata Das2012-12-274-13/+21
| * | Merge branch 'mesos' into dev-mergeTathagata Das2012-12-265-142/+90
| |\ \
| * \ \ Merge branch 'dev-checkpoint' of github.com:radlab/spark into dev-mergeTathagata Das2012-12-2626-470/+921
| |\ \ \
| | * \ \ Merge branch 'dev' of github.com:radlab/spark into dev-checkpointTathagata Das2012-12-204-10/+29
| | |\ \ \
| | * | | | Fixed bugs in CheckpointRDD and spark.CheckpointSuite.Tathagata Das2012-12-203-12/+9
| | * | | | Changed checkpoint writing and reading process.Tathagata Das2012-12-203-25/+124
| | * | | | Introduced getSpits, getDependencies, and getPreferredLocations in RDD and RD...Tathagata Das2012-12-1822-113/+134
| | * | | | Converted CheckpointState in RDDCheckpointData to use scala Enumeration.Tathagata Das2012-12-171-26/+22
| | * | | | Made checkpoint data in RDDs optional to further reduce serialized size.Tathagata Das2012-12-113-14/+28
| | * | | | Fixed bug in UnionRDD and CoGroupedRDDTathagata Das2012-12-113-115/+10
| | * | | | Bunch of bug fixes related to checkpointing in RDDs. RDDCheckpointData object...Tathagata Das2012-12-1013-90/+389
| | * | | | Modified checkpoint testsuite to more comprehensively test checkpointing of v...Tathagata Das2012-12-0714-110/+285
| | * | | | Refactored RDD checkpointing to minimize extra fields in RDD class.Tathagata Das2012-12-0411-191/+140
| * | | | | Merge branch 'master' of github.com:mesos/spark into devReynold Xin2012-12-2071-850/+1940
| |\ \ \ \ \ | | |_|/ / / | |/| | | |
| * | | | | Added clear property to JavaAPISuite to remove port binding errors.Tathagata Das2012-12-111-0/+2
| * | | | | Merge pull request #5 from radlab/flume-integrationTathagata Das2012-12-092-3/+18
| |\ \ \ \ \
| | * | | | | Changes in response to TD's review.Patrick Wendell2012-12-071-3/+3
| | * | | | | Adding locality aware parallelizePatrick Wendell2012-12-072-3/+18
| | | |/ / / | | |/| | |
| * / | | | Removed unnecessary testcases.Tathagata Das2012-12-081-4/+4
| |/ / / /
| * | | | Added metadata cleaner to HttpBroadcast to clean up old broacast files.Tathagata Das2012-12-031-0/+24
| * | | | Made RDD checkpoint not create a new thread. Fixed bug in detecting when spar...Tathagata Das2012-12-022-22/+12
| * | | | Minor modifications.Tathagata Das2012-12-011-1/+6
| * | | | Added TimeStampedHashSet and used that to cleanup the list of registered RDD ...Tathagata Das2012-11-293-9/+81
| * | | | Added metadata cleaner to BlockManager to remove old blocks completely.Tathagata Das2012-11-282-12/+36
| * | | | Renamed CleanupTask to MetadataCleaner.Tathagata Das2012-11-285-14/+15
| * | | | Modified StorageLevel and BlockManagerId to cache common objects and use cach...Tathagata Das2012-11-284-29/+101