aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
Commit message (Expand)AuthorAgeFilesLines
* Merge branch 'master' into streamingTathagata Das2013-06-249-59/+132
|\
| * 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-291-1/+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-282-8/+30
| |/
| * method first in trait IterableLike is deprecated: use `head' insteadHolden Karau2013-03-241-1/+1
| * Forgot equals.Stephen Haberman2013-03-121-1/+1
| * More quickly call close in HadoopRDD.Stephen Haberman2013-03-111-35/+9
| * 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
| |/
| * 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-243-23/+48
|\ \ \
| * | | fixing kafkaStream Java API and adding testseanm2013-05-101-3/+7
| * | | fixing indentationseanm2013-05-101-1/+1
| * | | Surfacing decoders on KafkaInputDStreamseanm2013-04-163-20/+41
| |/ /
* | | 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-151-1/+4
|/ /
* | 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
|/
* Added back the initial spark job before starting streaming receiversTathagata Das2013-02-241-1/+1
* Updated streaming programming guide with Java API info, and comments from Pat...Tathagata Das2013-02-232-3/+2
* Fixed differences in APIs of StreamingContext and JavaStreamingContext. Chang...Tathagata Das2013-02-232-19/+198
* Merge branch 'mesos-streaming' into streamingTathagata Das2013-02-222-2/+56
|\
| * Merge pull request #479 from ScrapCodes/zeromq-streamingTathagata Das2013-02-222-2/+56
| |\
| | * fixes corresponding to review feedback at pull request #479Prashant Sharma2013-02-201-1/+1
| | * example for demonstrating ZeroMQ streamPrashant Sharma2013-02-191-8/+7
| | * ZeroMQ stream as receiverPrashant Sharma2013-02-192-0/+55
* | | Fixed condition in InputDStream isTimeValid.Tathagata Das2013-02-211-1/+1
|/ /
* | Merge branch 'mesos-streaming' into streamingTathagata Das2013-02-204-45/+54
|\ \
| * | Small changes that were missing in mergePatrick Wendell2013-02-191-0/+1
| * | Use RDD type for `slice` operator in Java.Patrick Wendell2013-02-191-2/+2
| * | Use RDD type for `transform` operator in Java.Patrick Wendell2013-02-191-5/+35
| * | Use RDD type for `foreach` operator in Java.Patrick Wendell2013-02-194-9/+17
| |/
* | Merge branch 'mesos-master' into streamingTathagata Das2013-02-208-21/+51
|\ \ | |/ |/|
| * Rename "jobs" to "applications" in the standalone clusterMatei Zaharia2013-02-173-9/+9
| * Make CoGroupedRDDs explicitly have the same key type.Stephen Haberman2013-02-163-3/+3
| * STREAMING-50: Support transform workaround in JavaPairDStreamPatrick Wendell2013-02-121-2/+32
| * Fix for MapPartitionsPatrick Wendell2013-02-111-2/+2
| * Fix for flatmapPatrick Wendell2013-02-111-2/+2
| * Initial cut at replacing K, V in Java filesPatrick Wendell2013-02-111-2/+2