aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* Add Apache license headers and LICENSE and NOTICE filesMatei Zaharia2013-07-169-2/+155
* Initialize Twitter4J OAuth from system properties instead of promptingMatei Zaharia2013-06-291-1/+1
* Merge branch 'master' into streamingTathagata Das2013-06-244-14/+25
|\
| * Remove debug statementsMridul Muralidharan2013-04-291-2/+0
| * Attempt to fix streaming test failures after yarn branch mergeMridul Muralidharan2013-04-285-1/+8
| * Move streaming test initialization into 'before' blocksJey Kottalam2013-03-282-4/+8
| * Instead of failing to bind to a fixed, already-in-use port, let the OS choose...Mark Hamstra2013-03-011-8/+10
| * Changed Flume test to use the same port as other tests, so that can be contro...Tathagata Das2013-02-251-2/+2
* | Merge pull request #571 from Reinvigorate/sm-kafka-serializersTathagata Das2013-06-242-4/+19
|\ \
| * | fixing kafkaStream Java API and adding testseanm2013-05-101-0/+6
| * | adding kafkaStream API testsseanm2013-05-102-2/+13
| * | Surfacing decoders on KafkaInputDStreamseanm2013-04-161-4/+2
| |/
* / fixing Spark Streaming count() so that 0 will be emitted when there is nothin...seanm2013-04-151-2/+2
|/
* Fixed differences in APIs of StreamingContext and JavaStreamingContext. Chang...Tathagata Das2013-02-232-6/+33
* Merge branch 'mesos-streaming' into streamingTathagata Das2013-02-202-4/+48
|\
| * Small changes that were missing in mergePatrick Wendell2013-02-191-0/+1
| * Use RDD type for `transform` operator in Java.Patrick Wendell2013-02-191-2/+87
| * Use RDD type for `foreach` operator in Java.Patrick Wendell2013-02-192-2/+4
* | Merge branch 'mesos-master' into streamingTathagata Das2013-02-201-3/+183
|\ \ | |/ |/|
| * STREAMING-50: Support transform workaround in JavaPairDStreamPatrick Wendell2013-02-121-0/+45
| * Using tuple swap()Patrick Wendell2013-02-111-2/+2
| * small fixPatrick Wendell2013-02-111-2/+2
| * Fix for MapPartitionsPatrick Wendell2013-02-111-15/+52
| * Fix for flatmapPatrick Wendell2013-02-111-0/+42
| * Indentation fixPatrick Wendell2013-02-111-10/+10
| * Initial cut at replacing K, V in Java filesPatrick Wendell2013-02-111-0/+56
* | Merge branch 'streaming' into ScrapCodes-streaming-actorTathagata Das2013-02-199-440/+443
|\ \
| * | Changed networkStream to socketStream and pluggableNetworkStream to become ne...Tathagata Das2013-02-182-4/+3
| * | Added checkpointing and fault-tolerance semantics to the programming guide. F...Tathagata Das2013-02-181-1/+1
| * | Many changes to ensure better 2nd recovery if 2nd failure happens whileTathagata Das2013-02-177-29/+67
| * | Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWind...Tathagata Das2013-02-143-55/+53
| * | Added filter functionality to reduceByKeyAndWindow with inverse. Consolidated...Tathagata Das2013-02-132-17/+34
| * | Changed scheduler and file input stream to fix bugs in the driver fault toler...Tathagata Das2013-02-138-348/+136
| * | Fixed bugs in FileInputDStream and Scheduler that occasionally failed to repr...Tathagata Das2013-02-101-81/+200
| * | Added an initial spark job to ensure worker nodes are initialized.Tathagata Das2013-02-091-1/+1
| * | Merge branch 'mesos-master' into streamingTathagata Das2013-02-077-6/+6
| |\|
| | * Replace old 'master' term with 'driver'.Stephen Haberman2013-01-256-6/+6
| | * Move JavaAPISuite into spark.streaming.Stephen Haberman2013-01-212-0/+0
| * | Merge branch 'mesos-streaming' into streamingTathagata Das2013-02-072-0/+50
| |\ \
| | * \ Merge pull request #373 from Reinvigorate/sm-updateStateByKeyTathagata Das2013-02-072-0/+50
| | |\ \ | | | |/ | | |/|
| | | * adding updateStateByKey object lifecycle testseanm2013-01-202-0/+50
| * | | Fixed checkpoint testcasesTathagata Das2013-01-233-172/+129
| * | | Added support for rescheduling unprocessed batches on master failure.Tathagata Das2013-01-231-7/+16
| * | | Added support for saving input files of FileInputDStream to graph checkpoints...Tathagata Das2013-01-221-20/+44
| * | | Refactored DStreamCheckpointData.Tathagata Das2013-01-221-6/+6
| |/ /
* / / actor as receiverPrashant Sharma2013-01-221-0/+68
|/ /
* | Fixed streaming testsuite bugsTathagata Das2013-01-207-6/+24
* | Moving tests to appropriate directoryPatrick Wendell2013-01-172-0/+0
* | Adding queueStream and some slight refactoringPatrick Wendell2013-01-171-81/+105
* | Merge branch 'streaming' into streaming-java-apiPatrick Wendell2013-01-171-3/+3
|\|
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-25 16:45:57 +0000