| Commit message (Expand) | Author | Age | Files | Lines |
* | PairDStream and DStreamLike | Patrick Wendell | 2013-01-14 | 2 | -3/+111 |
* | Adding transform and union | Patrick Wendell | 2013-01-14 | 1 | -4/+58 |
* | Reduce tests | Patrick Wendell | 2013-01-14 | 1 | -6/+63 |
* | Adding more tests | Patrick Wendell | 2013-01-14 | 1 | -9/+172 |
* | Better equality test (thanks Josh) | Patrick Wendell | 2013-01-14 | 1 | -4/+3 |
* | Remving main method from tests | Patrick Wendell | 2013-01-14 | 1 | -27/+0 |
* | Adding some initial tests to streaming API. | Patrick Wendell | 2013-01-14 | 2 | -0/+139 |
* | Fixed bug | Tathagata Das | 2013-01-13 | 1 | -1/+3 |
* | Changed variable name form ***Time to ***Duration to keep things consistent. | Tathagata Das | 2013-01-09 | 3 | -34/+34 |
* | Fixed bug | Tathagata Das | 2013-01-07 | 1 | -1/+1 |
* | Renamed examples and added documentation. | Tathagata Das | 2013-01-07 | 1 | -1/+1 |
* | Refactored a whole lot to push all DStreams into the spark.streaming.dstream ... | Tathagata Das | 2012-12-30 | 5 | -10/+55 |
* | Improved jekyll and scala docs. Made many classes and method private to remov... | Tathagata Das | 2012-12-29 | 1 | -1/+1 |
* | Adding Flume InputDStream | Patrick Wendell | 2012-12-07 | 1 | -2/+57 |
* | Merge branch 'dev' into kafka | Denny | 2012-12-05 | 3 | -13/+7 |
|\ |
|
| * | Modified StreamingContext API to make constructor accept the batch size (sinc... | Tathagata Das | 2012-11-19 | 3 | -13/+7 |
* | | Merge branch 'dev' into kafka | Denny | 2012-11-13 | 2 | -53/+60 |
|\| |
|
| * | Optimized checkpoint writing by reusing FileSystem object. Fixed bug in updat... | Tathagata Das | 2012-11-13 | 2 | -53/+60 |
* | | Merge branch 'dev' into kafka | Denny | 2012-11-12 | 2 | -28/+134 |
|\| |
|
| * | Speeded up CheckpointSuite | Tathagata Das | 2012-11-12 | 1 | -12/+14 |
| * | Fixed bug in FileInputDStream that allowed it to miss new files. Added tests ... | Tathagata Das | 2012-11-11 | 1 | -16/+120 |
* | | Kafka Stream comments. | Denny | 2012-11-11 | 1 | -6/+6 |
|/ |
|
* | Fixed bug in InputStreamsSuite | tdas | 2012-11-08 | 1 | -0/+2 |
* | Added FailureTestsuite for testing multiple, repeated master failures. | Tathagata Das | 2012-11-06 | 3 | -38/+234 |
* | Made more bug fixes for checkpointing. | Tathagata Das | 2012-11-05 | 1 | -27/+50 |
* | Fixed major bugs in checkpointing. | Tathagata Das | 2012-11-05 | 3 | -45/+137 |
* | Made checkpointing of dstream graph to work with checkpointing of RDDs. For s... | Tathagata Das | 2012-11-04 | 3 | -26/+92 |
* | Fixed serialization bug in countByWindow, added countByKey and countByKeyAndW... | Tathagata Das | 2012-11-02 | 3 | -43/+164 |
* | Merge branch 'dev' of github.com:radlab/spark into dev | Tathagata Das | 2012-10-25 | 1 | -1/+1 |
|\ |
|
| * | Merge remote-tracking branch 'public/master' into dev | Matei Zaharia | 2012-10-24 | 1 | -1/+1 |
* | | Added tests for the file input stream. | Tathagata Das | 2012-10-24 | 1 | -6/+62 |
|/ |
|
* | Minor fixes. | Tathagata Das | 2012-10-24 | 1 | -7/+9 |
* | Added tests for testing network input stream. | Tathagata Das | 2012-10-24 | 1 | -0/+112 |
* | Renamed the streaming testsuites. | Tathagata Das | 2012-10-23 | 4 | -6/+8 |
* | Updated StateDStream api to use Options instead of nulls. | Tathagata Das | 2012-10-23 | 1 | -5/+2 |
* | Added MapValueDStream, FlatMappedValuesDStream and CoGroupedDStream, and ther... | Tathagata Das | 2012-10-21 | 2 | -4/+141 |
* | Fixed some bugs in tests for forgetting RDDs, and made sure that use of manua... | Tathagata Das | 2012-10-21 | 3 | -59/+51 |
* | Added functionality to forget RDDs from DStreams. | Tathagata Das | 2012-10-19 | 3 | -15/+88 |
* | Minor modifications. | Tathagata Das | 2012-10-15 | 1 | -1/+1 |
* | Refactored DStreamSuiteBase to create CheckpointSuite- testsuite for testing ... | Tathagata Das | 2012-10-14 | 4 | -64/+199 |
* | Fixed bugs in the streaming testsuites. | Tathagata Das | 2012-10-13 | 2 | -7/+18 |
* | Fixed bugs and added testcases for naive reduceByKeyAndWindow. | Tathagata Das | 2012-09-06 | 2 | -50/+131 |
* | Re-implemented ReducedWindowedDSteam to simplify and fix bugs. Added slice op... | Tathagata Das | 2012-09-06 | 4 | -123/+242 |
* | Changed DStream member access permissions from private to protected. Updated... | Tathagata Das | 2012-09-04 | 1 | -2/+2 |
* | Added transformRDD DStream operation and TransformedDStream. Added sbt assemb... | Tathagata Das | 2012-09-02 | 1 | -1/+1 |
* | Added StateDStream, corresponding stateful stream operations, and testcases. ... | Tathagata Das | 2012-08-31 | 1 | -22/+68 |
* | Added capabllity to take streaming input from network. Renamed SparkStreamCon... | Tathagata Das | 2012-08-28 | 1 | -2/+2 |
* | Added new Clock interface that is used by RecurringTimer to scheduler events ... | Tathagata Das | 2012-08-06 | 1 | -8/+20 |
* | Renamed RDS to DStream, plus minor style fixes | Matei Zaharia | 2012-08-02 | 1 | -10/+10 |
* | 1. Refactored SparkStreamContext, Scheduler, InputRDS, FileInputRDS and a few... | Tathagata Das | 2012-08-01 | 1 | -0/+65 |