aboutsummaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Add Maven build file for streaming, and fix some issues in SBT fileMatei Zaharia2013-01-2014-7/+234
* Merge pull request #389 from JoshRosen/python_rdd_checkpointingMatei Zaharia2013-01-208-24/+132
|\
| * Clean up setup code in PySpark checkpointing testsJosh Rosen2013-01-202-16/+6
| * Update checkpointing API docs in Python/Java.Josh Rosen2013-01-204-34/+28
| * Add checkpointFile() and more tests to PySpark.Josh Rosen2013-01-203-2/+37
| * Add RDD checkpointing to Python API.Josh Rosen2013-01-206-4/+93
* | Merge pull request #390 from JoshRosen/spark-654Matei Zaharia2013-01-203-13/+22
|\ \ | |/ |/|
| * Fix PythonPartitioner equality; see SPARK-654.Josh Rosen2013-01-203-13/+22
|/
* Merge pull request #361 from mesos/streamingMatei Zaharia2013-01-20124-332/+10770
|\
| * Merge branch 'master' into streamingMatei Zaharia2013-01-2018-67/+424
| |\
| * \ 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
| | | * | | Some style cleanupPatrick Wendell2013-01-142-53/+93
| | | * | | Flume example and bug fixPatrick Wendell2013-01-142-2/+57
| | | * | | More work on InputStreamsPatrick Wendell2013-01-143-10/+130
| | | * | | Porting to new Duration classPatrick Wendell2013-01-145-78/+78
| | | * | | Fixing issue with <Long> typesPatrick Wendell2013-01-142-10/+16
| | | * | | More work on StreamingContextPatrick Wendell2013-01-141-2/+45
| | | * | | Import CleanupPatrick Wendell2013-01-143-4/+3
| | | * | | Some docs for the JavaTestUtilsPatrick Wendell2013-01-141-6/+22
| | | * | | Docs, some tests, and work onPatrick Wendell2013-01-145-32/+617
| | | * | | Squashing a few TODOsPatrick Wendell2013-01-141-4/+15
| | | * | | Style cleanup and moving functionsPatrick Wendell2013-01-143-67/+128
| | | * | | More pair functionsPatrick Wendell2013-01-141-1/+42
| | | * | | PairDStream and DStreamLikePatrick Wendell2013-01-145-100/+359
| | | * | | Adding transform and unionPatrick Wendell2013-01-142-4/+72
| | | * | | Reduce testsPatrick Wendell2013-01-141-6/+63
| | | * | | Adding more testsPatrick Wendell2013-01-142-10/+173
| | | * | | Better equality test (thanks Josh)Patrick Wendell2013-01-141-4/+3
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-07 01:30:44 +0000