- Feb 22, 2013
-
-
Tathagata Das authored
-
Tathagata Das authored
-
Tathagata Das authored
[Streaming] Examples using Twitter's Algebird library
-
Tathagata Das authored
Zeromq streaming
-
- Feb 21, 2013
-
-
Tathagata Das authored
-
Nick Pentreath authored
-
Nick Pentreath authored
-
Nick Pentreath authored
-
- Feb 20, 2013
-
-
Tathagata Das authored
Merged latest master changes to streaming
-
Tathagata Das authored
Conflicts: streaming/src/test/java/spark/streaming/JavaAPISuite.java
-
Tathagata Das authored
-
Tathagata Das authored
-
Tathagata Das authored
Conflicts: core/src/main/scala/spark/rdd/CheckpointRDD.scala streaming/src/main/scala/spark/streaming/dstream/ReducedWindowedDStream.scala
-
Prashant Sharma authored
-
Prashant Sharma authored
-
Tathagata Das authored
A bug fix to AkkaWordCount example.
-
Prashant Sharma authored
-
- Feb 19, 2013
-
-
Matei Zaharia authored
Don't call System.exit over uncaught exceptions from shutdown hooks
-
Charles Reiss authored
-
Matei Zaharia authored
Fixes a broken link in documentation to issue tracker
-
Matei Zaharia authored
Added a method to create PartitionPruningRDD.
-
Andy Konwinski authored
-
Reynold Xin authored
-
Charles Reiss authored
-
Charles Reiss authored
-
Tathagata Das authored
STREAMING-51: Add RDD type as a type parameter in JavaDStreamLike Edit (streaming/ version)
-
Patrick Wendell authored
-
Patrick Wendell authored
This commit uses the RDD type in `slice`, making it available to both normal and pair RDD's in java. It also updates the signature for `slice` to match changes in the Scala API.
-
Patrick Wendell authored
This is an improved implementation of the `transform` operator in Java. The main difference is that this allows all four possible types of transform functions 1. JavaRDD -> JavaRDD 2. JavaRDD -> JavaPairRDD 3. JavaPairRDD -> JavaPairRDD 4. JavaPairRDD -> JavaRDD whereas previously only (1) and (3) were possible. Conflicts: streaming/src/test/java/spark/streaming/JavaAPISuite.java
-
Patrick Wendell authored
-
Nick Pentreath authored
-
Nick Pentreath authored
-
Prashant Sharma authored
-
Prashant Sharma authored
-
Nick Pentreath authored
Conflicts: project/SparkBuild.scala
-
Nick Pentreath authored
-
Tathagata Das authored
Major modifications to fix driver fault-tolerance with file input stream
-
Tathagata Das authored
-
Tathagata Das authored
-
Tathagata Das authored
Conflicts: docs/plugin-custom-receiver.md streaming/src/main/scala/spark/streaming/StreamingContext.scala streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala streaming/src/main/scala/spark/streaming/dstream/PluggableInputDStream.scala streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala
-