aboutsummaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Merge pull request #373 from Reinvigorate/sm-updateStateByKeyTathagata Das2013-02-074-6/+78
|\
| * Splitting StreamingContext.queueStream into two methodsseanm2013-01-201-4/+18
| * adding updateStateByKey object lifecycle testseanm2013-01-202-0/+50
| * Merge branch 'streaming' into sm-updateStateByKeyseanm2013-01-154-11/+11
| |\
| * | StateDStream changes to give updateStateByKey consistent behaviorseanm2013-01-141-2/+10
* | | Merge branch 'master' into streamingMatei Zaharia2013-01-2018-67/+424
|\ \ \
| * \ \ Merge pull request #387 from mateiz/python-accumulatorsJosh Rosen2013-01-2010-22/+305
| |\ \ \
| | * | | Fix Python guide to say accumulators are availableMatei Zaharia2013-01-201-1/+0
| | * | | Add a class comment to AccumulatorMatei Zaharia2013-01-201-0/+12
| | * | | Launch accumulator tests in run-testsMatei Zaharia2013-01-201-0/+3
| | * | | Added accumulators to PySparkMatei Zaharia2013-01-208-21/+290
| * | | | Minor formatting fixesMatei Zaharia2013-01-202-3/+3
| * | | | Merge pull request #376 from MLnick/python-alsMatei Zaharia2013-01-202-39/+91
| |\ \ \ \
| | * | | | Use only one update function and pass in transpose of ratings matrix where ap...Nick Pentreath2013-01-171-29/+3
| | * | | | Fixed index error missing first argumentNick Pentreath2013-01-171-1/+1
| | * | | | Adding default command line args to SparkALSNick Pentreath2013-01-171-10/+17
| | * | | | Python ALS exampleNick Pentreath2013-01-151-0/+71
| * | | | | Merge pull request #385 from pwendell/ec2-guide-fixMatei Zaharia2013-01-201-1/+3
| |\ \ \ \ \ | | |_|/ / / | |/| | | |
| | * | | | Changes based on Matei's commentPatrick Wendell2013-01-201-2/+3
| | * | | | Clarifying log directory in EC2 guidePatrick Wendell2013-01-191-1/+2
| |/ / / /
| * | | | Fix code that assumed spark.local.dir is only a single directoryMatei Zaharia2013-01-172-2/+11
| * | | | Merge pull request #382 from fanuo/masterMatei Zaharia2013-01-171-1/+1
| |\ \ \ \
| | * | | | changed HttpBroadcast server cache to be in spark.local.dir instead of java.i...Fernand Pajot2013-01-171-1/+1
| |/ / / /
| * | | | Merge branch 'master' of github.com:mesos/sparkMatei Zaharia2013-01-171-3/+0
| |\ \ \ \
| | * \ \ \ Merge pull request #381 from squito/remove_threadpoolMatei Zaharia2013-01-161-3/+0
| | |\ \ \ \
| | | * | | | remove unused thread poolImran Rashid2013-01-161-3/+0
| | | |/ / /
| * | / / / Warn users if they run pyspark or spark-shell without compiling SparkMatei Zaharia2013-01-172-0/+14
| |/ / / /
* | | | | Merge pull request #380 from tdas/streamingTathagata Das2013-01-2082-319/+3579
|\ \ \ \ \
| * | | | | Fixed streaming testsuite bugsTathagata Das2013-01-207-6/+24
| * | | | | Merge branch 'mesos-streaming' into streamingTathagata Das2013-01-2017-152/+2768
| |\ \ \ \ \ | |/ / / / / |/| | | | |
* | | | | | Merge pull request #369 from pwendell/streaming-java-apiPatrick Wendell2013-01-1715-121/+2708
|\ \ \ \ \ \ | |_|_|_|_|/ |/| | | | |
| * | | | | NetworkWordCount examplePatrick Wendell2013-01-172-1/+63
| * | | | | Moving tests to appropriate directoryPatrick Wendell2013-01-172-0/+0
| * | | | | Adding queueStream and some slight refactoringPatrick Wendell2013-01-174-83/+226
| * | | | | Small doc fixPatrick Wendell2013-01-171-1/+1
| * | | | | Merge branch 'streaming' into streaming-java-apiPatrick Wendell2013-01-172-6/+6
| |\ \ \ \ \ | |/ / / / / |/| | | | |
* | | | | | Merge pull request #375 from tdas/streamingTathagata Das2013-01-144-11/+11
|\ \ \ \ \ \ | |_|_|_|_|/ |/| | | | |
| | * | | | Import fixupPatrick Wendell2013-01-173-3/+0
| | * | | | Style cleanupPatrick Wendell2013-01-173-3/+26
| | * | | | Checkpointing in Streaming java APIPatrick Wendell2013-01-173-3/+93
| | * | | | Adding flatMapPatrick Wendell2013-01-172-4/+106
| | * | | | Adding checkpointing to Java APIPatrick Wendell2013-01-173-0/+81
| | * | | | Adding other updateState functionsPatrick Wendell2013-01-171-13/+49
| | * | | | Bug fix and test cleanupPatrick Wendell2013-01-172-9/+12
| | * | | | StashPatrick Wendell2013-01-142-1/+61
| | * | | | BugfixPatrick Wendell2013-01-141-2/+4
| | * | | | Remove AnyRef constraint in updateStatePatrick Wendell2013-01-142-5/+5
| | * | | | Bug fixPatrick Wendell2013-01-141-2/+1
| | * | | | Making comments consistent w/ Spark stylePatrick Wendell2013-01-145-232/+196
| | * | | | Two changes:Patrick Wendell2013-01-143-7/+271