spark - Mirror of Apache Spark

	Commit message (Collapse)	Author	Age	Files	Lines
*	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