| Commit message (Expand) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | | | * | Streaming constructor which takes JavaSparkContext | Patrick Wendell | 2013-02-05 | 1 | -0/+8 | |
| | | | * | Remove activation of profiles by default | Mikhail Bautin | 2013-01-31 | 1 | -11/+0 | |
| | | | * | Merge pull request #415 from stephenh/driver | Matei Zaharia | 2013-01-29 | 7 | -8/+8 | |
| | | | |\ | ||||||
| | | | | * | Replace old 'master' term with 'driver'. | Stephen Haberman | 2013-01-25 | 7 | -8/+8 | |
| | | | * | | Fix code that depended on metadata cleaner interval being in minutes | Matei Zaharia | 2013-01-28 | 2 | -5/+5 | |
| | | | |/ | ||||||
| | | | * | Refactor daemon thread pool creation. | Josh Rosen | 2013-01-21 | 1 | -2/+3 | |
| | | | * | Move JavaAPISuite into spark.streaming. | Stephen Haberman | 2013-01-21 | 2 | -0/+0 | |
| | | | * | Add Maven build file for streaming, and fix some issues in SBT file | Matei Zaharia | 2013-01-20 | 10 | -0/+182 | |
| | | * | | Updated JavaStreamingContext with updated kafkaStream API. | Tathagata Das | 2013-02-07 | 1 | -17/+9 | |
| | | * | | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-02-07 | 5 | -88/+91 | |
| | | |\ \ | ||||||
| | | | * \ | Merge pull request #372 from Reinvigorate/sm-kafka | Tathagata Das | 2013-02-07 | 2 | -91/+13 | |
| | | | |\ \ | ||||||
| | | | | * | | kafkaStream API cleanup. A quorum of zookeepers can now be specified | seanm | 2013-01-18 | 2 | -15/+10 | |
| | | | | * | | further KafkaInputDStream cleanup (removing unused and commented out code rel... | seanm | 2013-01-18 | 1 | -69/+3 | |
| | | | | * | | Removing offset management code that is non-existent in kafka 0.7.0+ | seanm | 2013-01-14 | 1 | -7/+0 | |
| | | | * | | | Merge pull request #373 from Reinvigorate/sm-updateStateByKey | Tathagata Das | 2013-02-07 | 4 | -6/+78 | |
| | | | |\ \ \ | | | | |_|/ | | | |/| | | ||||||
| | | | | * | | Splitting StreamingContext.queueStream into two methods | seanm | 2013-01-20 | 1 | -4/+18 | |
| | | | | * | | adding updateStateByKey object lifecycle test | seanm | 2013-01-20 | 2 | -0/+50 | |
| | | | | * | | Merge branch 'streaming' into sm-updateStateByKey | seanm | 2013-01-15 | 3 | -8/+8 | |
| | | | | |\ \ | ||||||
| | | | | * | | | StateDStream changes to give updateStateByKey consistent behavior | seanm | 2013-01-14 | 1 | -2/+10 | |
| | | | | | |/ | | | | |/| | ||||||
| | | * | | | | Fixed checkpoint testcases | Tathagata Das | 2013-01-23 | 3 | -172/+129 | |
| | | * | | | | Added support for rescheduling unprocessed batches on master failure. | Tathagata Das | 2013-01-23 | 5 | -12/+53 | |
| | | * | | | | Added support for saving input files of FileInputDStream to graph checkpoints... | Tathagata Das | 2013-01-22 | 6 | -66/+159 | |
| | | * | | | | Refactored DStreamCheckpointData. | Tathagata Das | 2013-01-22 | 4 | -64/+99 | |
| | | |/ / / | ||||||
| | * | | | | Plug in actor as stream receiver API | Prashant Sharma | 2013-01-19 | 3 | -0/+152 | |
| | * | | | | Changed method name of createReceiver to getReceiver as it is not intended to... | Prashant Sharma | 2013-01-19 | 6 | -28/+28 | |
| * | | | | | actor as receiver | Prashant Sharma | 2013-01-22 | 4 | -0/+269 | |
| * | | | | | Changed method name of createReceiver to getReceiver as it is not intended to... | Prashant Sharma | 2013-01-21 | 6 | -8/+8 | |
| | |/ / / |/| | | | ||||||
| * | | | | Fixed streaming testsuite bugs | Tathagata Das | 2013-01-20 | 7 | -6/+24 | |
| * | | | | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-01-20 | 8 | -120/+2452 | |
| |\| | | | ||||||
| | * | | | Moving tests to appropriate directory | Patrick Wendell | 2013-01-17 | 2 | -0/+0 | |
| | * | | | Adding queueStream and some slight refactoring | Patrick Wendell | 2013-01-17 | 2 | -81/+163 | |
| | * | | | Merge branch 'streaming' into streaming-java-api | Patrick Wendell | 2013-01-17 | 1 | -3/+3 | |
| | |\ \ \ | | | |/ | | |/| | ||||||
| | * | | | 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 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 | 2 | -5/+269 | |
| | * | | | Some style cleanup | Patrick Wendell | 2013-01-14 | 2 | -53/+93 | |
| | * | | | Flume example and bug fix | Patrick Wendell | 2013-01-14 | 1 | -2/+7 | |
| | * | | | 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 | |
| | * | | | Fixing issue with <Long> types | Patrick Wendell | 2013-01-14 | 2 | -10/+16 | |
| | * | | | More work on StreamingContext | Patrick Wendell | 2013-01-14 | 1 | -2/+45 | |
 |
index : spark | |
| Mirror of Apache Spark |
| aboutsummaryrefslogtreecommitdiff |