| Commit message (Expand) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | | | * | | | | | Moved Twitter example to the where the other examples are. | Tathagata Das | 2013-01-07 | 2 | -10/+11 | |
| | | | * | | | | | Merge branch 'streaming-merge' into dev-merge | Tathagata Das | 2013-01-07 | 3 | -1/+108 | |
| | | | |\ \ \ \ \ | ||||||
| | | | | * \ \ \ \ | Merge pull request #8 from radlab/twitter-example | Patrick Wendell | 2012-12-29 | 3 | -1/+108 | |
| | | | | |\ \ \ \ \ | ||||||
| | | | | | * | | | | | Minor changes after review and general cleanup. | Patrick Wendell | 2012-12-21 | 2 | -11/+19 | |
| | | | | | * | | | | | Adding a Twitter InputDStream with an example | Patrick Wendell | 2012-12-21 | 3 | -1/+100 | |
| | | | * | | | | | | | Merge branch 'dev' into dev-merge | Tathagata Das | 2013-01-07 | 35 | -356/+181 | |
| | | | |\ \ \ \ \ \ \ | | | |/ / / / / / / | | |/| | | | | | | | ||||||
| | | * | | | | | | | | Changed locations for unit test logs. | Tathagata Das | 2013-01-07 | 4 | -8/+8 | |
| | | * | | | | | | | | Fixed bug | Tathagata Das | 2013-01-07 | 1 | -1/+1 | |
| | | * | | | | | | | | Added better docs for RDDCheckpointData | Tathagata Das | 2013-01-07 | 2 | -1/+13 | |
| | | * | | | | | | | | Renamed examples and added documentation. | Tathagata Das | 2013-01-07 | 15 | -304/+141 | |
| | | * | | | | | | | | Changed cleanup to clearOldValues for TimeStampedHashMap and TimeStampedHashSet. | Tathagata Das | 2013-01-07 | 7 | -12/+18 | |
| | | * | | | | | | | | Moved Spark Streaming examples to examples sub-project. | Tathagata Das | 2013-01-06 | 13 | -2/+1 | |
| | | * | | | | | | | | Removed streaming-env.sh.template | Tathagata Das | 2013-01-06 | 3 | -29/+0 | |
| | | | * | | | | | | | Merge branch 'dev-merge' of github.com:radlab/spark into dev-merge | Tathagata Das | 2013-01-07 | 5 | -99/+90 | |
| | | |/| | | | | | | | ||||||
| | | | * | | | | | | | Merge pull request #10 from radlab/datahandler-fix | Patrick Wendell | 2013-01-02 | 5 | -99/+90 | |
| | | | |\ \ \ \ \ \ \ | ||||||
| | | | | * | | | | | | | BufferingBlockCreator -> NetworkReceiver.BlockGenerator | Patrick Wendell | 2013-01-02 | 5 | -94/+89 | |
| | | | | * | | | | | | | Merge branch 'dev-merge' into datahandler-fix | Patrick Wendell | 2013-01-02 | 54 | -538/+919 | |
| | | | | |\ \ \ \ \ \ \ | | | | |/ / / / / / / | | | |/| | | | | | | | ||||||
| | | | | * | | | | | | | Several code-quality improvements to DataHandler. | Patrick Wendell | 2013-01-02 | 5 | -88/+84 | |
| | | * | | | | | | | | | Fixed compilation bug in RDDSuite created during merge for mesos/master. | Tathagata Das | 2013-01-01 | 1 | -3/+3 | |
| | | * | | | | | | | | | Merge branch 'mesos' into dev-merge | Tathagata Das | 2013-01-01 | 10 | -47/+187 | |
| | | |\ \ \ \ \ \ \ \ \ | | | |/ / / / / / / / | | |/| | | | | | | | | ||||||
| | | * | | | | | | | | | Updated Streaming Programming Guide. | Tathagata Das | 2013-01-01 | 5 | -17/+179 | |
| | | * | | | | | | | | | More classes made private[streaming] to hide from scala docs. | Tathagata Das | 2012-12-30 | 18 | -52/+137 | |
| | | * | | | | | | | | | Refactored a whole lot to push all DStreams into the spark.streaming.dstream ... | Tathagata Das | 2012-12-30 | 41 | -333/+402 | |
| | | * | | | | | | | | | Improved jekyll and scala docs. Made many classes and method private to remov... | Tathagata Das | 2012-12-29 | 19 | -168/+233 | |
| | | | |/ / / / / / / | | |/| | | | | | | | ||||||
| | | * | | | | | | | | Modifications to make sure LocalScheduler terminate cleanly without errors wh... | Tathagata Das | 2012-12-27 | 5 | -18/+29 | |
| | | * | | | | | | | | Merge branch 'mesos' into dev-merge | Tathagata Das | 2012-12-26 | 8 | -158/+108 | |
| | | |\ \ \ \ \ \ \ \ | ||||||
| | | * \ \ \ \ \ \ \ \ | Merge branch 'dev-checkpoint' of github.com:radlab/spark into dev-merge | Tathagata Das | 2012-12-26 | 27 | -479/+930 | |
| | | |\ \ \ \ \ \ \ \ \ | | | |_|_|/ / / / / / | | |/| | | | | | | | | ||||||
| | | | * | | | | | | | | Merge branch 'dev' of github.com:radlab/spark into dev-checkpoint | Tathagata Das | 2012-12-20 | 19 | -122/+717 | |
| | | | |\ \ \ \ \ \ \ \ | ||||||
| | | | * | | | | | | | | | Fixed bugs in CheckpointRDD and spark.CheckpointSuite. | Tathagata Das | 2012-12-20 | 3 | -12/+9 | |
| | | | * | | | | | | | | | Changed checkpoint writing and reading process. | Tathagata Das | 2012-12-20 | 3 | -25/+124 | |
| | | | * | | | | | | | | | Introduced getSpits, getDependencies, and getPreferredLocations in RDD and RD... | Tathagata Das | 2012-12-18 | 22 | -113/+134 | |
| | | | * | | | | | | | | | Converted CheckpointState in RDDCheckpointData to use scala Enumeration. | Tathagata Das | 2012-12-17 | 1 | -26/+22 | |
| | | | * | | | | | | | | | Made checkpoint data in RDDs optional to further reduce serialized size. | Tathagata Das | 2012-12-11 | 4 | -17/+29 | |
| | | | * | | | | | | | | | Fixed bug in UnionRDD and CoGroupedRDD | Tathagata Das | 2012-12-11 | 3 | -115/+10 | |
| | | | * | | | | | | | | | Bunch of bug fixes related to checkpointing in RDDs. RDDCheckpointData object... | Tathagata Das | 2012-12-10 | 13 | -90/+389 | |
| | | | * | | | | | | | | | Modified checkpoint testsuite to more comprehensively test checkpointing of v... | Tathagata Das | 2012-12-07 | 14 | -110/+285 | |
| | | | * | | | | | | | | | Refactored RDD checkpointing to minimize extra fields in RDD class. | Tathagata Das | 2012-12-04 | 12 | -194/+144 | |
| | | * | | | | | | | | | | Merge branch 'master' of github.com:mesos/spark into dev | Reynold Xin | 2012-12-20 | 90 | -899/+3244 | |
| | | |\ \ \ \ \ \ \ \ \ \ | | | |_|/ / / / / / / / | | |/| | | | | | | | | | ||||||
| | | * | | | | | | | | | | Added clear property to JavaAPISuite to remove port binding errors. | Tathagata Das | 2012-12-11 | 1 | -0/+2 | |
| | | * | | | | | | | | | | Merge pull request #5 from radlab/flume-integration | Tathagata Das | 2012-12-09 | 11 | -10/+280 | |
| | | |\ \ \ \ \ \ \ \ \ \ | ||||||
| | | | * | | | | | | | | | | Changes in response to TD's review. | Patrick Wendell | 2012-12-07 | 7 | -18/+32 | |
| | | | * | | | | | | | | | | Adding Flume InputDStream | Patrick Wendell | 2012-12-07 | 9 | -7/+248 | |
| | | | * | | | | | | | | | | Adding locality aware parallelize | Patrick Wendell | 2012-12-07 | 2 | -3/+18 | |
| | | | | |_|_|_|/ / / / / | | | |/| | | | | | | | | ||||||
| | | * / | | | | | | | | | Removed unnecessary testcases. | Tathagata Das | 2012-12-08 | 1 | -4/+4 | |
| | | |/ / / / / / / / / | ||||||
| | | * | | | | | | | | | Added kafka JAR | Denny | 2012-12-05 | 2 | -1/+1 | |
| | | * | | | | | | | | | Adjust Kafka code to work with new streaming changes. | Denny | 2012-12-05 | 2 | -4/+5 | |
| | | * | | | | | | | | | Merge branch 'dev' into kafka | Denny | 2012-12-05 | 69 | -355/+1024 | |
| | | |\ \ \ \ \ \ \ \ \ | | | | |/ / / / / / / | | | |/| | | | | | | | ||||||
| | | | * | | | | | | | | Added metadata cleaner to HttpBroadcast to clean up old broacast files. | Tathagata Das | 2012-12-03 | 1 | -0/+24 | |
| | | | * | | | | | | | | Minor mods | Tathagata Das | 2012-12-02 | 1 | -1/+1 | |
| | | | * | | | | | | | | Made RDD checkpoint not create a new thread. Fixed bug in detecting when spar... | Tathagata Das | 2012-12-02 | 3 | -26/+17 | |
 |
index : spark | |
| Mirror of Apache Spark |
| aboutsummaryrefslogtreecommitdiff |