spark - Mirror of Apache Spark

	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	2	-1/+2
\| \| \| \|	in log4j.properties of external modules.
*	Removed StreamingContext.registerInputStream and registerOutputStream - they ↵	Tathagata Das	2014-01-13	1	-3/+1
\| \| \| \|	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	1	-1/+1
\|
*	Fixed persistence logic of WindowedDStream, and fixed default persistence ↵	Tathagata Das	2014-01-12	1	-0/+1
\| \| \| \|	level of input streams.
*	Moved DStream, DStreamCheckpointData and PairDStream from ↵	Tathagata Das	2014-01-12	1	-1/+2
\| \| \| \|	org.apache.spark.streaming to org.apache.spark.streaming.dstream.
*	Fixed bugs.	Tathagata Das	2014-01-12	1	-1/+1
\|
*	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	5	-92/+39
\| \| \| \|	for creating XYZ streams.
*	Changed JavaStreamingContextWith* to Function in streaming.api.java.** ↵	Tathagata Das	2014-01-06	5	-11/+9
\| \| \| \|	package. Also fixed packages of Flume and MQTT tests.
*	Refactored kafka, flume, zeromq, mqtt as separate external projects, with ↵	Tathagata Das	2013-12-30	7	-0/+342
	their own self-contained scala API, java API, scala unit tests and java unit tests. Updated examples to use the external projects.