aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
Commit message (Expand)AuthorAgeFilesLines
* Merge branch 'master' of github.com:apache/incubator-spark into scala-2.10-tempPrashant Sharma2013-11-212-3/+3
|\
| * Remove the semicolons at the end of Scala code to make it more pure Scala code.Henry Saputra2013-11-192-3/+3
* | Merge branch 'master' into scala-2.10Raymond Liu2013-11-141-5/+78
|\|
| * Made block generator thread safe to fix Kafka bug.Tathagata Das2013-11-121-5/+78
* | Merge branch 'master' into scala-2.10Raymond Liu2013-11-136-40/+635
|\|
| * Merge branch 'apache-master' into transformTathagata Das2013-10-255-15/+157
| |\
| | * Style fixesPatrick Wendell2013-10-241-9/+9
| | * Spacing fixPatrick Wendell2013-10-241-4/+4
| | * Small spacing fixPatrick Wendell2013-10-241-2/+2
| | * Adding Java versions and associated testsPatrick Wendell2013-10-242-0/+56
| | * Some clean-up of testsPatrick Wendell2013-10-243-7/+10
| | * Adding testsPatrick Wendell2013-10-242-5/+88
| * | Fixed accidental bug.Tathagata Das2013-10-241-1/+1
| * | Added JavaStreamingContext.transformTathagata Das2013-10-241-30/+102
| * | Merge branch 'apache-master' into transformTathagata Das2013-10-222-7/+17
| |\|
| | * Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streamingjerryshao2013-10-122-7/+17
| * | Fixed bug in Java transformWith, added more Java testcases for transform and ...Tathagata Das2013-10-221-15/+204
| * | Updated TransformDStream to allow n-ary DStream transform. Added transformWit...Tathagata Das2013-10-212-5/+187
| |/
* | fixed some warningsMartin Weindel2013-10-051-46/+48
* | Akka 2.2 migrationPrashant Sharma2013-09-221-1/+1
* | Few more fixes to tests broken during mergePrashant Sharma2013-09-101-3/+3
* | Merged with masterPrashant Sharma2013-09-0610-87/+244
|\|
| * Move some classes to more appropriate packages:Matei Zaharia2013-09-011-2/+3
| * Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-018-47/+48
| * Add Apache license headers and LICENSE and NOTICE filesMatei Zaharia2013-07-169-2/+155
* | Merge branch 'master' into master-mergePrashant Sharma2013-07-035-7/+27
|\|
| * 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
| * | 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 Warning: ClassManifest -> ClassTagPrashant Sharma2013-04-293-24/+28
* | | Fixed breaking tests in streaming checkpoint suite. Changed RichInt to Int as...Prashant Sharma2013-04-251-16/+19
| |/ |/|
* | 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
|/
* 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