| Commit message (Expand) | Author | Age | Files | Lines |
|---|
| * | 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 |
