aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* Add Apache license headers and LICENSE and NOTICE filesMatei Zaharia2013-07-1660-6/+1026
* Merge pull request #688 from markhamstra/scalaDependenciesMatei Zaharia2013-07-081-0/+4
|\
| * pom cleanupMark Hamstra2013-07-081-1/+0
| * Explicit dependencies for scala-library and scalap to prevent 2.9.2 vs. 2.9.3...Mark Hamstra2013-07-081-0/+5
* | 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
* | 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-2414-75/+202
|\|
| * Exclude old versions of Netty from Maven-based buildJey Kottalam2013-05-181-0/+6
| * 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
| * | Attempt at fixing merge conflictMridul Muralidharan2013-04-241-1/+1
| |\ \
| | * \ Merge remote-tracking branch 'jey/bump-development-version-to-0.8.0'Matei Zaharia2013-04-081-1/+1
| | |\ \ | | | |/ | | |/|
| | | * Bump development version to 0.8.0Jey Kottalam2013-03-281-1/+1
| * | | Add support for building against hadoop2-yarn : adding new maven profile for itMridul Muralidharan2013-04-071-0/+37
| |/ /
| * / Move streaming test initialization into 'before' blocksJey Kottalam2013-03-282-4/+8
| |/
| * method first in trait IterableLike is deprecated: use `head' insteadHolden Karau2013-03-241-1/+1
| * Add a log4j compile dependency to fix build in IntelliJMikhail Bautin2013-03-151-1/+1
| * Forgot equals.Stephen Haberman2013-03-121-1/+1
| * More quickly call close in HadoopRDD.Stephen Haberman2013-03-111-35/+9
| * Instead of failing to bind to a fixed, already-in-use port, let the OS choose...Mark Hamstra2013-03-011-8/+10
| * bump version to 0.7.1-SNAPSHOT in the subproject poms to keep the maven build...Mark Hamstra2013-02-281-1/+1
| * Merge pull request #503 from pwendell/bug-fixMatei Zaharia2013-02-251-1/+1
| |\
| | * createNewSparkContext should use sparkHome/jars/environment.Patrick Wendell2013-02-251-1/+1
| * | Pass a code JAR to SparkContext in our examples. Fixes SPARK-594.Matei Zaharia2013-02-251-0/+17
| |/
| * Changed Flume test to use the same port as other tests, so that can be contro...Tathagata Das2013-02-251-2/+2
| * Fixed something that was reported as a compile error in ScalaDoc.Matei Zaharia2013-02-252-3/+3
| * Allow passing sparkHome and JARs to StreamingContext constructorMatei Zaharia2013-02-254-10/+68
* | 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
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-26 03:20:32 +0000