aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
...
| * | | | 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
|/ /
* | 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
|/
* Fixed class paths and dependencies based on Matei's comments.Tathagata Das2013-02-241-11/+0
* Added back the initial spark job before starting streaming receiversTathagata Das2013-02-241-1/+1
* Fixed missing dependencies in streaming/pom.xmlTathagata Das2013-02-241-4/+14
* 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-234-25/+231
* Merge branch 'mesos-streaming' into streamingTathagata Das2013-02-223-2/+66
|\
| * Merge pull request #480 from MLnick/streaming-eg-algebirdTathagata Das2013-02-221-0/+10
| |\
| | * Merge remote-tracking branch 'upstream/streaming' into streaming-eg-algebirdNick Pentreath2013-02-2111-43/+306
| | |\
| | * | Dependencies and refactoring for streaming HLL example, and using context.twi...Nick Pentreath2013-02-191-0/+10
| * | | 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-206-49/+102
|\ \
| * | Small changes that were missing in mergePatrick Wendell2013-02-192-0/+2
| * | 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-192-7/+122
| * | Use RDD type for `foreach` operator in Java.Patrick Wendell2013-02-196-11/+21
| |/
* | Merge branch 'mesos-master' into streamingTathagata Das2013-02-209-24/+234
|\ \ | |/ |/|
| * 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
generated by cgit v1.2.3 (git 2.39.1) at 2024-08-31 19:26:33 +0000