aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* Rename "jobs" to "applications" in the standalone clusterMatei Zaharia2013-02-173-9/+9
* Make CoGroupedRDDs explicitly have the same key type.Stephen Haberman2013-02-163-3/+3
* STREAMING-50: Support transform workaround in JavaPairDStreamPatrick Wendell2013-02-121-2/+32
* Fix for MapPartitionsPatrick Wendell2013-02-111-2/+2
* Fix for flatmapPatrick Wendell2013-02-111-2/+2
* Initial cut at replacing K, V in Java filesPatrick Wendell2013-02-111-2/+2
* Streaming constructor which takes JavaSparkContextPatrick Wendell2013-02-051-0/+8
* Merge pull request #415 from stephenh/driverMatei Zaharia2013-01-291-2/+2
|\
| * Replace old 'master' term with 'driver'.Stephen Haberman2013-01-251-2/+2
* | Fix code that depended on metadata cleaner interval being in minutesMatei Zaharia2013-01-282-5/+5
|/
* Refactor daemon thread pool creation.Josh Rosen2013-01-211-2/+3
* Merge branch 'mesos-streaming' into streamingTathagata Das2013-01-206-120/+1360
|\
| * Adding queueStream and some slight refactoringPatrick Wendell2013-01-171-0/+58
| * Import fixupPatrick Wendell2013-01-172-2/+0
| * Style cleanupPatrick Wendell2013-01-173-3/+26
| * Checkpointing in Streaming java APIPatrick Wendell2013-01-171-2/+17
| * Adding flatMapPatrick Wendell2013-01-171-0/+29
| * Adding other updateState functionsPatrick Wendell2013-01-171-13/+49
| * Bug fix and test cleanupPatrick Wendell2013-01-171-2/+2
| * StashPatrick Wendell2013-01-141-1/+28
| * 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-142-5/+269
| * Some style cleanupPatrick Wendell2013-01-142-53/+93
| * Flume example and bug fixPatrick Wendell2013-01-141-2/+7
| * More work on InputStreamsPatrick Wendell2013-01-142-9/+62
| * Porting to new Duration classPatrick Wendell2013-01-144-68/+68
| * Fixing issue with <Long> typesPatrick Wendell2013-01-141-6/+12
| * More work on StreamingContextPatrick Wendell2013-01-141-2/+45
| * Import CleanupPatrick Wendell2013-01-142-2/+1
| * Docs, some tests, and work onPatrick Wendell2013-01-144-7/+283
| * 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-143-97/+248
| * Adding transform and unionPatrick Wendell2013-01-141-0/+14
| * Adding more testsPatrick Wendell2013-01-141-1/+1
| * Adding some initial tests to streaming API.Patrick Wendell2013-01-142-64/+1
| * A very rough, early cut at some Java functionality for Streaming.Patrick Wendell2013-01-143-0/+188
* | Fixed issue https://spark-project.atlassian.net/browse/STREAMING-29, along wi...Tathagata Das2013-01-191-1/+7
* | Fixed updateStateByKey to work with primitive types.Tathagata Das2013-01-142-5/+5
|/
* Minor name fixTathagata Das2013-01-131-2/+2
* Added documentation for PairDStreamFunctions.Tathagata Das2013-01-133-27/+303
* Removed stream id from the constructor of NetworkReceiver to make it easier f...Tathagata Das2013-01-136-30/+68
* Changed variable name form ***Time to ***Duration to keep things consistent.Tathagata Das2013-01-0923-152/+142
* Split Time to Time (absolute instant of time) and Duration (duration of time).Tathagata Das2013-01-0925-152/+174
* Moved Twitter example to the where the other examples are.Tathagata Das2013-01-072-104/+0
* Merge branch 'streaming-merge' into dev-mergeTathagata Das2013-01-072-0/+104
|\
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-12 17:36:26 +0000