Commit message (Expand) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| | * | | | Updated streaming programming guide with Java API info, and comments from Pat... | Tathagata Das | 2013-02-23 | 3 | -14/+76 | |
| | * | | | Change spark.cleaner.delay to spark.cleaner.ttl. Updated docs. | Tathagata Das | 2013-02-23 | 3 | -6/+6 | |
| | * | | | Fixed differences in APIs of StreamingContext and JavaStreamingContext. Chang... | Tathagata Das | 2013-02-23 | 5 | -26/+232 | |
| | * | | | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-02-22 | 8 | -8/+313 | |
| | |\ \ \ | | |/ / / | |/| | | | ||||||
| * | | | | Fixed resolver for akka-zeromq | Tathagata Das | 2013-02-22 | 1 | -0/+3 | |
| * | | | | Merge pull request #480 from MLnick/streaming-eg-algebird | Tathagata Das | 2013-02-22 | 5 | -5/+179 | |
| |\ \ \ \ | ||||||
| | * | | | | Adding documentation for HLL and CMS examples. More efficient and clear use o... | Nick Pentreath | 2013-02-21 | 2 | -12/+36 | |
| | * | | | | Bumping Algebird to 0.1.9 | Nick Pentreath | 2013-02-21 | 2 | -2/+2 | |
| | * | | | | Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird | Nick Pentreath | 2013-02-21 | 115 | -922/+1528 | |
| | |\ \ \ \ | ||||||
| | * | | | | | Streaming example using Twitter Algebird's Count Min Sketch monoid | Nick Pentreath | 2013-02-19 | 1 | -0/+78 | |
| | * | | | | | Dependencies and refactoring for streaming HLL example, and using context.twi... | Nick Pentreath | 2013-02-19 | 3 | -21/+24 | |
| | * | | | | | Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebird | Nick Pentreath | 2013-02-19 | 55 | -1138/+2543 | |
| | |\ \ \ \ \ | ||||||
| | * | | | | | | Adding streaming HyperLogLog example using Algebird | Nick Pentreath | 2013-02-19 | 3 | -1/+69 | |
| * | | | | | | | Merge pull request #479 from ScrapCodes/zeromq-streaming | Tathagata Das | 2013-02-22 | 4 | -3/+131 | |
| |\ \ \ \ \ \ \ | | |_|_|/ / / / | |/| | | | | | | ||||||
| | * | | | | | | removed document on zeromq | Prashant Sharma | 2013-02-20 | 1 | -59/+0 | |
| | * | | | | | | fixes corresponding to review feedback at pull request #479 | Prashant Sharma | 2013-02-20 | 3 | -6/+9 | |
| | * | | | | | | example for demonstrating ZeroMQ stream | Prashant Sharma | 2013-02-19 | 2 | -8/+77 | |
| | * | | | | | | ZeroMQ stream as receiver | Prashant Sharma | 2013-02-19 | 4 | -0/+115 | |
| | | |/ / / / | | |/| | | | | ||||||
| * | | | | | | Merge pull request #487 from tdas/streaming | Tathagata Das | 2013-02-20 | 113 | -903/+1387 | |
| |\ \ \ \ \ \ | ||||||
| | | | | * | | | Fixed condition in InputDStream isTimeValid. | Tathagata Das | 2013-02-21 | 1 | -1/+1 | |
| | | |_|/ / / | | |/| | | | | ||||||
| | * | | | | | Merge branch 'mesos-streaming' into streaming | Tathagata Das | 2013-02-20 | 7 | -50/+103 | |
| | |\ \ \ \ \ | | |/ / / / / | |/| | | | | | ||||||
| * | | | | | | Merge pull request #486 from ScrapCodes/akka-example-bug-fix | Tathagata Das | 2013-02-20 | 1 | -1/+1 | |
| |\ \ \ \ \ \ | ||||||
| | * | | | | | | A bug fix post merge, following changes to AkkaUtils | Prashant Sharma | 2013-02-20 | 1 | -1/+1 | |
| | | |/ / / / | | |/| | | | | ||||||
| * | | | | | | Merge pull request #481 from pwendell/stream-rdd-type-streaming | Tathagata Das | 2013-02-19 | 6 | -19/+146 | |
| |\ \ \ \ \ \ | | |/ / / / / | |/| | | | | | ||||||
| | * | | | | | Small changes that were missing in merge | Patrick Wendell | 2013-02-19 | 2 | -0/+2 | |
| | * | | | | | Use RDD type for `slice` operator in Java. | Patrick Wendell | 2013-02-19 | 1 | -2/+2 | |
| | * | | | | | Use RDD type for `transform` operator in Java. | Patrick Wendell | 2013-02-19 | 2 | -7/+122 | |
| | * | | | | | Use RDD type for `foreach` operator in Java. | Patrick Wendell | 2013-02-19 | 6 | -11/+21 | |
| |/ / / / / | ||||||
| * | | | | | Merge pull request #476 from tdas/streaming | Tathagata Das | 2013-02-19 | 52 | -862/+2142 | |
| |\ \ \ \ \ | ||||||
| | | * | | | | Fixed bug in CheckpointSuite | Tathagata Das | 2013-02-20 | 2 | -6/+6 | |
| | | * | | | | Merge branch 'mesos-master' into streaming | Tathagata Das | 2013-02-20 | 6 | -8/+51 | |
| | | |\ \ \ \ | ||||||
| | | * | | | | | Merge branch 'mesos-master' into streaming | Tathagata Das | 2013-02-20 | 109 | -893/+1408 | |
| | |/| | | | | | ||||||
| | * | | | | | | Added comment to the KafkaWordCount, given by Sean McNamara. | Tathagata Das | 2013-02-19 | 1 | -0/+12 | |
| | * | | | | | | 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 | |
| | | |_|/ / / / / / | | |/| | | | | | | |