Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Changed SparkConf to not be serializable. And also fixed unit-test log paths ↵ | Tathagata Das | 2014-01-14 | 9 | -5/+9 |
| | | | | in log4j.properties of external modules. | ||||
* | Removed StreamingContext.registerInputStream and registerOutputStream - they ↵ | Tathagata Das | 2014-01-13 | 5 | -11/+4 |
| | | | | were useless as InputDStream has been made to register itself. Also made DStream.register() private[streaming] - not useful to expose the confusing function. Updated a lot of documentation. | ||||
* | Fixed import formatting. | Tathagata Das | 2014-01-12 | 5 | -5/+5 |
| | |||||
* | Fixed persistence logic of WindowedDStream, and fixed default persistence ↵ | Tathagata Das | 2014-01-12 | 4 | -1/+8 |
| | | | | level of input streams. | ||||
* | Moved DStream, DStreamCheckpointData and PairDStream from ↵ | Tathagata Das | 2014-01-12 | 5 | -5/+10 |
| | | | | org.apache.spark.streaming to org.apache.spark.streaming.dstream. | ||||
* | Fixed bugs. | Tathagata Das | 2014-01-12 | 2 | -2/+2 |
| | |||||
* | Merge pull request #373 from jerryshao/kafka-upgrade | Patrick Wendell | 2014-01-11 | 1 | -2/+2 |
|\ | | | | | | | Upgrade Kafka dependecy to 0.8.0 release version | ||||
| * | Upgrade Kafka dependecy to 0.8.0 release version | jerryshao | 2014-01-10 | 1 | -2/+2 |
| | | |||||
* | | Change clientId to random clientId | Prabeesh K | 2014-01-10 | 1 | -1/+1 |
|/ | | | Returns a randomly generated client identifier based on the current user's login name and the system time. | ||||
* | Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ↵ | Tathagata Das | 2014-01-07 | 26 | -629/+369 |
| | | | | for creating XYZ streams. | ||||
* | Merge remote-tracking branch 'apache/master' into project-refactor | Tathagata Das | 2014-01-06 | 1 | -1/+1 |
| | | | | | | | | | | Conflicts: examples/src/main/java/org/apache/spark/streaming/examples/JavaFlumeEventCount.java streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala | ||||
* | Changed JavaStreamingContextWith*** to ***Function in streaming.api.java.*** ↵ | Tathagata Das | 2014-01-06 | 13 | -70/+61 |
| | | | | package. Also fixed packages of Flume and MQTT tests. | ||||
* | Removed extra empty lines. | Tathagata Das | 2013-12-31 | 2 | -2/+0 |
| | |||||
* | Added pom.xml for external projects and removed unnecessary dependencies and ↵ | Tathagata Das | 2013-12-31 | 5 | -0/+476 |
| | | | | repositoris from other poms and sbt. | ||||
* | Refactored kafka, flume, zeromq, mqtt as separate external projects, with ↵ | Tathagata Das | 2013-12-30 | 35 | -30/+1894 |
| | | | | their own self-contained scala API, java API, scala unit tests and java unit tests. Updated examples to use the external projects. | ||||
* | Refactored streaming project to separate out the twitter functionality. | Tathagata Das | 2013-12-26 | 3 | -0/+135 |