aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
Commit message (Expand)AuthorAgeFilesLines
* Akka 2.2 migrationPrashant Sharma2013-09-226-12/+15
* Few more fixes to tests broken during mergePrashant Sharma2013-09-101-3/+3
* Merged with masterPrashant Sharma2013-09-0676-699/+1706
|\
| * Move some classes to more appropriate packages:Matei Zaharia2013-09-0131-60/+70
| * Initial work to rename package to org.apache.sparkMatei Zaharia2013-09-0158-258/+263
| * Merge pull request #701 from ScrapCodes/documentation-suggestionsMatei Zaharia2013-08-223-3/+7
| |\
| | * Linking custom receiver guidePrashant Sharma2013-08-232-0/+4
| | * Corrections in documentation commentPrashant Sharma2013-08-231-3/+3
| * | Change scala.Option to Guava Optional in Java APIs.Josh Rosen2013-08-111-5/+2
| * | Changed other LZF uses to use the compression codec interface.Reynold Xin2013-07-311-9/+17
| * | Add Apache license headers and LICENSE and NOTICE filesMatei Zaharia2013-07-1659-6/+1009
| |/
* | code formatting, The warning related to scope exit and enter is not worth fix...Prashant Sharma2013-07-161-14/+14
* | Fixed warning erasure -> runtimeClassPrashant Sharma2013-07-161-1/+1
* | Fixed warning ThrowablesPrashant Sharma2013-07-161-1/+1
* | Fixed warning ClassManifest -> ClassTagPrashant Sharma2013-07-161-1/+1
* | Merge branch 'master' into master-mergePrashant Sharma2013-07-125-18/+25
|\|
| * Catch RejectedExecution exception in Checkpoint handler.Shivaram Venkataraman2013-07-071-2/+7
| * Merge remote-tracking branch 'pwendell/ui-updates'Matei Zaharia2013-07-061-1/+5
| |\
| | * Handful of changes based on matei's reviewPatrick Wendell2013-06-271-1/+5
| * | Merge pull request #655 from tgravescs/masterMatei Zaharia2013-07-061-1/+2
| |\ \
| | * | Rework from pull request. Removed --user option from Spark on Yarn Client, ma...Y.CORP.YAHOO.COM\tgraves2013-07-021-4/+0
| | * | Add support for Spark on Yarn on a secure Hadoop clusterThomas Graves2013-06-191-1/+6
| | |/
| * | Reduced the number of Iterator to ArrayBuffer copies in NetworkReceiver.Tathagata Das2013-07-052-14/+11
* | | Merge branch 'master' into master-mergePrashant Sharma2013-07-0315-148/+249
|\| |
| * | Initialize Twitter4J OAuth from system properties instead of promptingMatei Zaharia2013-06-294-38/+23
| * | Merge remote-tracking branch 'mrpotes/master'Matei Zaharia2013-06-293-35/+85
| |\ \
| | * | Include a default OAuth implementation, and update examples and JavaStreaming...James Phillpotts2013-06-253-25/+78
| | * | Twitter API v1 is retired - username/password auth no longer possibleJames Phillpotts2013-06-241-15/+1
| | * | Allow other twitter authorizations than username/passwordJames Phillpotts2013-06-212-9/+20
| | |/
| * | Merge branch 'master' into streamingTathagata Das2013-06-2413-73/+157
| |\|
| | * Merge branch 'shuffle-performance-fix-0.7' of github.com:shane-huang/spark in...Reynold Xin2013-05-071-1/+1
| | |\
| | | * Shuffle Performance fix: Use netty embeded OIO file server instead of Connect...shane-huang2013-04-071-1/+1
| | * | Remove debug statementsMridul Muralidharan2013-04-292-3/+0
| | * | Make log message more descriptive to aid in debuggingMridul Muralidharan2013-04-291-1/+3
| | * | Allow CheckpointWriter pending tasks to finishMridul Muralidharan2013-04-282-7/+8
| | * | Attempt to fix streaming test failures after yarn branch mergeMridul Muralidharan2013-04-287-9/+38
| | |/
| * | Minor formatting fixesTathagata Das2013-06-243-19/+34
| * | Merge pull request #572 from Reinvigorate/sm-block-intervalTathagata Das2013-06-241-1/+1
| |\ \
| | * | adding spark.streaming.blockInterval propertyseanm2013-04-161-1/+1
| * | | Merge pull request #571 from Reinvigorate/sm-kafka-serializersTathagata Das2013-06-245-27/+67
| |\ \ \
| | * | | fixing kafkaStream Java API and adding testseanm2013-05-102-3/+13
| | * | | fixing indentationseanm2013-05-101-1/+1
| | * | | adding kafkaStream API testsseanm2013-05-102-2/+13
| | * | | Surfacing decoders on KafkaInputDStreamseanm2013-04-164-24/+43
| | |/ /
| * | | count() now uses a transform instead of ConstantInputDStreamseanm2013-05-101-4/+1
| * | | fixing Spark Streaming count() so that 0 will be emitted when there is nothin...seanm2013-04-152-3/+6
| |/ /
| * | fixing autooffset.reset behavior when set to 'largest'seanm2013-03-261-4/+6
| * | keeping JavaStreamingContext in sync with StreamingContext + adding comments ...seanm2013-03-152-6/+7
| * | removing dependency on ZookeeperConsumerConnector + purging last relic of kaf...seanm2013-03-153-59/+6
| * | fixing memory leak in kafka MessageHandlerseanm2013-03-141-4/+1
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-11 17:40:49 +0000