aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test/java
Commit message (Expand)AuthorAgeFilesLines
...
| * Merge remote-tracking branch 'apache/master' into project-refactorTathagata Das2014-01-061-1/+3
| |\
| * | Removed unnecessary comments.Tathagata Das2013-12-311-26/+0
| * | Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-302-70/+56
* | | Merge remote-tracking branch 'spark/master'Andrew Or2014-01-021-3/+7
|\ \ \ | | |/ | |/|
| * | Fix other failing testsMatei Zaharia2013-12-281-3/+6
| * | Fix test failures due to setting / clearing clock type in StreamingMatei Zaharia2013-12-281-3/+4
| |/
* | Address Aaron's commentsAndrew Or2013-12-291-4/+4
* | Fix streaming JavaAPISuite againAndrew Or2013-12-261-8/+12
* | Fix streaming JavaAPISuite that depended on orderAaron Davidson2013-12-261-11/+16
|/
* Merge branch 'master' into scala-2.10Raymond Liu2013-11-132-28/+433
|\
| * Merge branch 'apache-master' into transformTathagata Das2013-10-252-7/+62
| |\
| | * 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-241-2/+1
| * | 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-221-5/+11
| |\|
| | * Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streamingjerryshao2013-10-121-5/+11
| * | 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-211-3/+86
| |/
* | fixed some warningsMartin Weindel2013-10-051-46/+48
* | Akka 2.2 migrationPrashant Sharma2013-09-221-1/+1
* | Merged with masterPrashant Sharma2013-09-062-25/+60
|\|
| * Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-012-24/+25
| * Add Apache license headers and LICENSE and NOTICE filesMatei Zaharia2013-07-162-1/+35
* | Merge branch 'master' into master-mergePrashant Sharma2013-07-031-5/+9
|\|
| * Initialize Twitter4J OAuth from system properties instead of promptingMatei Zaharia2013-06-291-1/+1
| * fixing kafkaStream Java API and adding testseanm2013-05-101-0/+6
| * adding kafkaStream API testsseanm2013-05-101-2/+2
| * Surfacing decoders on KafkaInputDStreamseanm2013-04-161-4/+2
* | Fixed Warning: ClassManifest -> ClassTagPrashant Sharma2013-04-291-10/+12
|/
* Fixed differences in APIs of StreamingContext and JavaStreamingContext. Chang...Tathagata Das2013-02-231-5/+32
* 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
* | Changed networkStream to socketStream and pluggableNetworkStream to become ne...Tathagata Das2013-02-181-3/+2
* | Many changes to ensure better 2nd recovery if 2nd failure happens whileTathagata Das2013-02-172-16/+39
* | Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWind...Tathagata Das2013-02-141-49/+30
* | Changed scheduler and file input stream to fix bugs in the driver fault toler...Tathagata Das2013-02-131-10/+11
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-13 11:13:58 +0000