Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Changed method name of createReceiver to getReceiver as it is not intended to... | Prashant Sharma | 2013-01-21 | 7 | -9/+9 |
* | Merge branch 'master' into streaming | Matei Zaharia | 2013-01-20 | 18 | -67/+424 |
|\ | |||||
| * | Merge pull request #387 from mateiz/python-accumulators | Josh Rosen | 2013-01-20 | 10 | -22/+305 |
| |\ | |||||
| | * | Fix Python guide to say accumulators are available | Matei Zaharia | 2013-01-20 | 1 | -1/+0 |
| | * | Add a class comment to Accumulator | Matei Zaharia | 2013-01-20 | 1 | -0/+12 |
| | * | Launch accumulator tests in run-tests | Matei Zaharia | 2013-01-20 | 1 | -0/+3 |
| | * | Added accumulators to PySpark | Matei Zaharia | 2013-01-20 | 8 | -21/+290 |
| * | | Minor formatting fixes | Matei Zaharia | 2013-01-20 | 2 | -3/+3 |
| * | | Merge pull request #376 from MLnick/python-als | Matei Zaharia | 2013-01-20 | 2 | -39/+91 |
| |\ \ | |||||
| | * | | Use only one update function and pass in transpose of ratings matrix where ap... | Nick Pentreath | 2013-01-17 | 1 | -29/+3 |
| | * | | Fixed index error missing first argument | Nick Pentreath | 2013-01-17 | 1 | -1/+1 |
| | * | | Adding default command line args to SparkALS | Nick Pentreath | 2013-01-17 | 1 | -10/+17 |
| | * | | Python ALS example | Nick Pentreath | 2013-01-15 | 1 | -0/+71 |
| * | | | Merge pull request #385 from pwendell/ec2-guide-fix | Matei Zaharia | 2013-01-20 | 1 | -1/+3 |
| |\ \ \ | | |_|/ | |/| | | |||||
| | * | | Changes based on Matei's comment | Patrick Wendell | 2013-01-20 | 1 | -2/+3 |
| | * | | Clarifying log directory in EC2 guide | Patrick Wendell | 2013-01-19 | 1 | -1/+2 |
| |/ / | |||||
| * | | Fix code that assumed spark.local.dir is only a single directory | Matei Zaharia | 2013-01-17 | 2 | -2/+11 |
| * | | Merge pull request #382 from fanuo/master | Matei Zaharia | 2013-01-17 | 1 | -1/+1 |
| |\ \ | |||||
| | * | | changed HttpBroadcast server cache to be in spark.local.dir instead of java.i... | Fernand Pajot | 2013-01-17 | 1 | -1/+1 |
| |/ / | |||||
| * | | Merge branch 'master' of github.com:mesos/spark | Matei Zaharia | 2013-01-17 | 1 | -3/+0 |
| |\ \ | |||||
| | * \ | Merge pull request #381 from squito/remove_threadpool | Matei Zaharia | 2013-01-16 | 1 | -3/+0 |
| | |\ \ | |||||
| | | * | | remove unused thread pool | Imran Rashid | 2013-01-16 | 1 | -3/+0 |
| | | |/ | |||||
| * | / | Warn users if they run pyspark or spark-shell without compiling Spark | Matei Zaharia | 2013-01-17 | 2 | -0/+14 |
| |/ / | |||||
* | | | Merge pull request #380 from tdas/streaming | Tathagata Das | 2013-01-20 | 82 | -319/+3579 |
|\ \ \ | |||||
| * | | | Fixed streaming testsuite bugs | Tathagata Das | 2013-01-20 | 7 | -6/+24 |
| * | | | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-01-20 | 17 | -152/+2768 |
| |\ \ \ | |/ / / |/| | | | |||||
* | | | | Merge pull request #369 from pwendell/streaming-java-api | Patrick Wendell | 2013-01-17 | 15 | -121/+2708 |
|\ \ \ \ | |||||
| * | | | | NetworkWordCount example | Patrick Wendell | 2013-01-17 | 2 | -1/+63 |
| * | | | | Moving tests to appropriate directory | Patrick Wendell | 2013-01-17 | 2 | -0/+0 |
| * | | | | Adding queueStream and some slight refactoring | Patrick Wendell | 2013-01-17 | 4 | -83/+226 |
| * | | | | Small doc fix | Patrick Wendell | 2013-01-17 | 1 | -1/+1 |
| * | | | | Merge branch 'streaming' into streaming-java-api | Patrick Wendell | 2013-01-17 | 2 | -6/+6 |
| |\ \ \ \ | |/ / / / |/| | | | | |||||
* | | | | | Merge pull request #375 from tdas/streaming | Tathagata Das | 2013-01-14 | 4 | -11/+11 |
|\ \ \ \ \ | |||||
| | * | | | | Import fixup | Patrick Wendell | 2013-01-17 | 3 | -3/+0 |
| | * | | | | Style cleanup | Patrick Wendell | 2013-01-17 | 3 | -3/+26 |
| | * | | | | Checkpointing in Streaming java API | Patrick Wendell | 2013-01-17 | 3 | -3/+93 |
| | * | | | | Adding flatMap | Patrick Wendell | 2013-01-17 | 2 | -4/+106 |
| | * | | | | Adding checkpointing to Java API | Patrick Wendell | 2013-01-17 | 3 | -0/+81 |
| | * | | | | Adding other updateState functions | Patrick Wendell | 2013-01-17 | 1 | -13/+49 |
| | * | | | | Bug fix and test cleanup | Patrick Wendell | 2013-01-17 | 2 | -9/+12 |
| | * | | | | Stash | Patrick Wendell | 2013-01-14 | 2 | -1/+61 |
| | * | | | | Bugfix | Patrick Wendell | 2013-01-14 | 1 | -2/+4 |
| | * | | | | Remove AnyRef constraint in updateState | Patrick Wendell | 2013-01-14 | 2 | -5/+5 |
| | * | | | | Bug fix | Patrick Wendell | 2013-01-14 | 1 | -2/+1 |
| | * | | | | Making comments consistent w/ Spark style | Patrick Wendell | 2013-01-14 | 5 | -232/+196 |
| | * | | | | Two changes: | Patrick Wendell | 2013-01-14 | 3 | -7/+271 |
| | * | | | | Some style cleanup | Patrick Wendell | 2013-01-14 | 2 | -53/+93 |
| | * | | | | Flume example and bug fix | Patrick Wendell | 2013-01-14 | 2 | -2/+57 |
| | * | | | | More work on InputStreams | Patrick Wendell | 2013-01-14 | 3 | -10/+130 |
| | * | | | | Porting to new Duration class | Patrick Wendell | 2013-01-14 | 5 | -78/+78 |