aboutsummaryrefslogtreecommitdiff
path: root/streaming
Commit message (Expand)AuthorAgeFilesLines
* 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
| * STREAMING-50: Support transform workaround in JavaPairDStreamPatrick Wendell2013-02-122-2/+77
| * Using tuple swap()Patrick Wendell2013-02-111-2/+2
| * small fixPatrick Wendell2013-02-111-2/+2
| * Fix for MapPartitionsPatrick Wendell2013-02-112-17/+54
| * Fix for flatmapPatrick Wendell2013-02-112-2/+44
| * Indentation fixPatrick Wendell2013-02-111-10/+10
| * Initial cut at replacing K, V in Java filesPatrick Wendell2013-02-112-2/+58
* | Merge branch 'streaming' into ScrapCodes-streaming-actorTathagata Das2013-02-1946-1056/+2026
|\ \
| * | Changed networkStream to socketStream and pluggableNetworkStream to become ne...Tathagata Das2013-02-184-21/+22
| * | Merge branch 'streaming' into ScrapCode-streamingTathagata Das2013-02-1845-1027/+2015
| |\ \
| | * | Added checkpointing and fault-tolerance semantics to the programming guide. F...Tathagata Das2013-02-186-6/+11
| | * | Many changes to ensure better 2nd recovery if 2nd failure happens whileTathagata Das2013-02-1718-97/+208
| | * | Made MasterFailureTest more robust.Tathagata Das2013-02-151-4/+22
| | * | Moved Java streaming examples to examples/src/main/java/spark/streaming/... a...Tathagata Das2013-02-141-1/+1
| | * | Added TwitterInputDStream from example to StreamingContext. Renamed example T...Tathagata Das2013-02-142-17/+105
| | * | Removed countByKeyAndWindow on paired DStreams, and added countByValueAndWind...Tathagata Das2013-02-148-183/+226
| | * | Changes functions comments to make them more consistent.Tathagata Das2013-02-132-45/+45
| | * | Added filter functionality to reduceByKeyAndWindow with inverse. Consolidated...Tathagata Das2013-02-137-81/+102
| | * | Changed scheduler and file input stream to fix bugs in the driver fault toler...Tathagata Das2013-02-1318-452/+693
| | * | Fixed bugs in FileInputDStream and Scheduler that occasionally failed to repr...Tathagata Das2013-02-106-91/+221
| | * | Added an initial spark job to ensure worker nodes are initialized.Tathagata Das2013-02-092-2/+7
| | * | Merge branch 'mesos-master' into streamingTathagata Das2013-02-0722-15/+195
| | |\|
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-16 03:50:49 +0000