aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test/java
Commit message (Expand)AuthorAgeFilesLines
* 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
* 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 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
* | Merge branch 'mesos-master' into streamingTathagata Das2013-02-072-1/+1
|\|
| * Replace old 'master' term with 'driver'.Stephen Haberman2013-01-251-1/+1
| * Move JavaAPISuite into spark.streaming.Stephen Haberman2013-01-212-0/+0
* | Fixed checkpoint testcasesTathagata Das2013-01-231-11/+12
|/
* Fixed streaming testsuite bugsTathagata Das2013-01-201-0/+2
* Moving tests to appropriate directoryPatrick Wendell2013-01-172-0/+1092