Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-02-19 | 0 | -0/+0 |
|\ | |||||
| * | Merge pull request #455 from tdas/streaming | Tathagata Das | 2013-02-07 | 183 | -2473/+4256 |
| |\ | |||||
* | \ | Merge branch 'streaming' into ScrapCodes-streaming-actor | Tathagata Das | 2013-02-19 | 209 | -3356/+5876 |
|\ \ \ | |||||
| * | | | Changed networkStream to socketStream and pluggableNetworkStream to become ne... | Tathagata Das | 2013-02-18 | 9 | -35/+36 |
| * | | | Merge branch 'streaming' into ScrapCode-streaming | Tathagata Das | 2013-02-18 | 242 | -3438/+9569 |
| |\ \ \ | |||||
| | * | | | Added checkpointing and fault-tolerance semantics to the programming guide. F... | Tathagata Das | 2013-02-18 | 8 | -59/+206 |
| | * | | | Many changes to ensure better 2nd recovery if 2nd failure happens while | Tathagata Das | 2013-02-17 | 18 | -97/+208 |
| | * | | | Made MasterFailureTest more robust. | Tathagata Das | 2013-02-15 | 1 | -4/+22 |
| | * | | | Moved Java streaming examples to examples/src/main/java/spark/streaming/... a... | Tathagata Das | 2013-02-14 | 4 | -1/+1 |
| | * | | | Added TwitterInputDStream from example to StreamingContext. Renamed example T... | Tathagata Das | 2013-02-14 | 4 | -45/+53 |
| | * | | | Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWind... | Tathagata Das | 2013-02-14 | 9 | -189/+231 |
| | * | | | Changes functions comments to make them more consistent. | Tathagata Das | 2013-02-13 | 2 | -45/+45 |
| | * | | | Added filter functionality to reduceByKeyAndWindow with inverse. Consolidated... | Tathagata Das | 2013-02-13 | 7 | -81/+102 |
| | * | | | Changed scheduler and file input stream to fix bugs in the driver fault toler... | Tathagata Das | 2013-02-13 | 18 | -452/+693 |
| | * | | | Fixed bugs in FileInputDStream and Scheduler that occasionally failed to repr... | Tathagata Das | 2013-02-10 | 6 | -91/+221 |
| | * | | | Fixed bug in CheckpointRDD to prevent exception when the original RDD had zer... | Tathagata Das | 2013-02-10 | 2 | -2/+12 |
| | * | | | Added an initial spark job to ensure worker nodes are initialized. | Tathagata Das | 2013-02-09 | 2 | -2/+7 |
| | | |/ | | |/| | |||||
| | * | | Merge branch 'mesos-master' into streaming | Tathagata Das | 2013-02-07 | 177 | -2220/+3876 |
| | |\ \ | |||||
| | | * \ | Merge pull request #450 from stephenh/inlinemergepair | Matei Zaharia | 2013-02-05 | 1 | -6/+4 |
| | | |\ \ | |||||
| | | | * | | Inline mergePair to look more like the narrow dep branch. | Stephen Haberman | 2013-02-05 | 1 | -6/+4 |
| | | * | | | Merge pull request #451 from stephenh/fixdeathpactexception | Matei Zaharia | 2013-02-05 | 2 | -19/+13 |
| | | |\ \ \ | |||||
| | | | * \ \ | Merge branch 'master' into fixdeathpactexception | Stephen Haberman | 2013-02-05 | 30 | -258/+991 |
| | | | |\ \ \ | | | | |/ / / | | | |/| | | | |||||
| | | * | | | | Merge pull request #449 from stephenh/longerdriversuite | Matei Zaharia | 2013-02-05 | 1 | -1/+2 |
| | | |\ \ \ \ | |||||
| | | | * | | | | Increase DriverSuite timeout. | Stephen Haberman | 2013-02-05 | 1 | -1/+2 |
| | | | | |/ / | | | | |/| | | |||||
| | | * | | | | Merge pull request #447 from pwendell/streaming-constructor | Matei Zaharia | 2013-02-05 | 1 | -0/+8 |
| | | |\ \ \ \ | |||||
| | | | * | | | | Streaming constructor which takes JavaSparkContext | Patrick Wendell | 2013-02-05 | 1 | -0/+8 |
| | | |/ / / / | |||||
| | | * | | | | Small fix to test for distinct | Matei Zaharia | 2013-02-04 | 1 | -1/+1 |
| | | * | | | | Fix failing test | Matei Zaharia | 2013-02-04 | 1 | -2/+1 |
| | | * | | | | Merge pull request #445 from JoshRosen/pyspark_fixes | Matei Zaharia | 2013-02-03 | 5 | -22/+19 |
| | | |\ \ \ \ | |||||
| | | | * | | | | Remove unnecessary doctest __main__ methods. | Josh Rosen | 2013-02-03 | 2 | -18/+0 |
| | | | * | | | | Fetch fewer objects in PySpark's take() method. | Josh Rosen | 2013-02-03 | 2 | -2/+13 |
| | | | * | | | | Fix reporting of PySpark doctest failures. | Josh Rosen | 2013-02-03 | 2 | -2/+6 |
| | | | |/ / / | |||||
| | | * | | | | Merge pull request #379 from stephenh/sparkmem | Matei Zaharia | 2013-02-02 | 6 | -35/+17 |
| | | |\ \ \ \ | |||||
| | | | * | | | | Fix dangling old variable names. | Stephen Haberman | 2013-02-02 | 1 | -2/+2 |
| | | | * | | | | Move executorMemory up into SchedulerBackend. | Stephen Haberman | 2013-02-02 | 4 | -29/+12 |
| | | | * | | | | Merge branch 'master' into sparkmem | Stephen Haberman | 2013-02-02 | 254 | -2124/+13947 |
| | | | |\| | | | |||||
| | | | * | | | | Fix SPARK_MEM in ExecutorRunner. | Stephen Haberman | 2013-01-22 | 1 | -1/+1 |
| | | | * | | | | Restore SPARK_MEM in executorEnvs. | Stephen Haberman | 2013-01-22 | 1 | -2/+3 |
| | | | * | | | | Add spark.executor.memory to differentiate executor memory from spark-shell m... | Stephen Haberman | 2013-01-15 | 3 | -10/+8 |
| | | * | | | | | Merge pull request #422 from squito/blockmanager_info | Matei Zaharia | 2013-02-02 | 6 | -38/+59 |
| | | |\ \ \ \ \ | |||||
| | | | * | | | | | remove unneeded (and unused) filter on block info | Imran Rashid | 2013-02-01 | 1 | -2/+0 |
| | | | * | | | | | track total partitions, in addition to cached partitions; use scala string fo... | Imran Rashid | 2013-02-01 | 3 | -9/+13 |
| | | | * | | | | | fixup merge (master -> driver renaming) | Imran Rashid | 2013-02-01 | 1 | -1/+1 |
| | | | * | | | | | Merge branch 'master' into blockmanager_info | Imran Rashid | 2013-01-30 | 43 | -246/+291 |
| | | | |\ \ \ \ \ | |||||
| | | | * | | | | | | rename Slaves --> Executor | Imran Rashid | 2013-01-30 | 2 | -5/+5 |
| | | | * | | | | | | Merge branch 'master' into blockmanager_info | Imran Rashid | 2013-01-29 | 23 | -192/+207 |
| | | | |\ \ \ \ \ \ | |||||
| | | | * | | | | | | | better formatting for RDDInfo | Imran Rashid | 2013-01-28 | 1 | -3/+9 |
| | | | * | | | | | | | expose RDD & storage info directly via SparkContext | Imran Rashid | 2013-01-28 | 4 | -28/+41 |
| | | * | | | | | | | | Merge pull request #436 from stephenh/removeextraloop | Matei Zaharia | 2013-02-02 | 1 | -13/+10 |
| | | |\ \ \ \ \ \ \ \ | |||||
| | | | * | | | | | | | | Further simplify checking for Nil. | Stephen Haberman | 2013-02-02 | 1 | -3/+1 |