| Commit message (Expand) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Adding some initial tests to streaming API. | Patrick Wendell | 2013-01-14 | 3 | -3/+79 |
| * | A very rough, early cut at some Java functionality for Streaming. | Patrick Wendell | 2013-01-14 | 4 | -1/+190 |
| * | Merge pull request #370 from tdas/streaming | Tathagata Das | 2013-01-13 | 13 | -89/+411 |
| |\ | |||||
| | * | Minor name fix | Tathagata Das | 2013-01-13 | 1 | -2/+2 |
| | * | Fixed bug | Tathagata Das | 2013-01-13 | 1 | -1/+3 |
| | * | Added documentation for PairDStreamFunctions. | Tathagata Das | 2013-01-13 | 5 | -50/+331 |
| | * | Removed stream id from the constructor of NetworkReceiver to make it easier f... | Tathagata Das | 2013-01-13 | 7 | -37/+76 |
| * | | Merge pull request #366 from tdas/streaming | Tathagata Das | 2013-01-13 | 36 | -378/+514 |
| |\| | |||||
| | * | Changed variable name form ***Time to ***Duration to keep things consistent. | Tathagata Das | 2013-01-09 | 26 | -186/+176 |
| | * | Split Time to Time (absolute instant of time) and Duration (duration of time). | Tathagata Das | 2013-01-09 | 25 | -152/+174 |
| | * | Making the Twitter example distributed. | Patrick Wendell | 2013-01-07 | 2 | -37/+62 |
| | * | 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 |
| | |\ \ \ | |||||
| | * \ \ \ | 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 |
| * | | | | | | | Merge pull request #365 from ryanlecompte/rate_limiter_timing_cleanup | Matei Zaharia | 2013-01-13 | 2 | -29/+58 |
| |\ \ \ \ \ \ \ | |||||
| | * | | | | | | | switch to uppercase constants | Ryan LeCompte | 2013-01-13 | 1 | -4/+4 |
| | * | | | | | | | more code cleanup | Ryan LeCompte | 2013-01-13 | 1 | -31/+32 |
| | * | | | | | | | add comment | Ryan LeCompte | 2013-01-12 | 1 | -0/+1 |
| | * | | | | | | | add one extra test | Ryan LeCompte | 2013-01-12 | 1 | -0/+1 |
| | * | | | | | | | correct test params | Ryan LeCompte | 2013-01-12 | 1 | -2/+2 |
| | * | | | | | | | add unit test | Ryan LeCompte | 2013-01-11 | 2 | -1/+23 |
| | * | | | | | | | add missing return | Ryan LeCompte | 2013-01-11 | 1 | -0/+1 |
| | * | | | | | | | attempt to sleep for more accurate time period, minor cleanup | Ryan LeCompte | 2013-01-11 | 1 | -8/+11 |
| |/ / / / / / / | |||||
| * | | | | | | | Merge pull request #350 from tdas/streaming | Matei Zaharia | 2013-01-07 | 109 | -319/+7742 |
| |\ \ \ \ \ \ \ | | |_|_|/ / / | |/| | | | | | |||||
| | * | | | | | | 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 |
| | |/ / / / / | |||||
| | * | | | | | 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 |
| | |\ \ \ \ \ | | |/ / / / | |/| | | | | |||||
| | | * | | | | Merge pull request #349 from woggling/cache-finally | Matei Zaharia | 2013-01-01 | 2 | -11/+28 |
| | | |\ \ \ \ | |||||
| | | | * | | | | Remove some dead comments | Charles Reiss | 2013-01-01 | 1 | -6/+0 |
| | | | * | | | | Test with exception while computing cached RDD. | Charles Reiss | 2013-01-01 | 1 | -0/+23 |
| | | | * | | | | Mark key as not loading in CacheTracker even when compute() fails | Charles Reiss | 2013-01-01 | 1 | -10/+10 |
| | | * | | | | | Merge pull request #348 from JoshRosen/spark-597 | Matei Zaharia | 2013-01-01 | 4 | -0/+58 |
| | | |\ \ \ \ \ | | | |/ / / / | | |/| | | | | |||||
| | | | * | | | | Raise exception when hashing Java arrays (SPARK-597) | Josh Rosen | 2012-12-31 | 4 | -0/+58 |
| | | |/ / / / | |||||
| | * | | | | | 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 |
 |
index : spark | |
| Mirror of Apache Spark |
| aboutsummaryrefslogtreecommitdiff |