aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* Merge branch 'master' into master-mergePrashant Sharma2013-07-0316-148/+292
|\
| * 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
| | |\ \
| | * | | Add support for building against hadoop2-yarn : adding new maven profile for itMridul Muralidharan2013-04-071-0/+37
| | | |/ | | |/|
| * | | 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
| * | | KafkaInputDStream improvements. Allows more Kafka configurabilityseanm2013-03-142-19/+51
* | | | Updated to latest stable scala 2.10.1 and akka 2.1.2Prashant Sharma2013-05-011-12/+2
* | | | Fixied other warningsPrashant Sharma2013-04-291-3/+1
* | | | Fixed warning: erasure -> runtimeClassPrashant Sharma2013-04-291-4/+4
* | | | Fixed Warning: ClassManifest -> ClassTagPrashant Sharma2013-04-2939-239/+285
* | | | Fixed pom.xml with updated dependencies.Prashant Sharma2013-04-291-1/+11
* | | | Fixed breaking tests in streaming checkpoint suite. Changed RichInt to Int as...Prashant Sharma2013-04-251-16/+19
* | | | scala 2.10 and master mergePrashant Sharma2013-04-244-15/+16
| |_|/ |/| |
* | | 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
* | | 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
|/ /