Made WordCount2 even more configurable
More fault tolerance fixes to catch lost tasks
Merge branch 'dev' of github.com:radlab/spark into dev
Log levels
Added capabllity to take streaming input from network. Renamed SparkStreamContext to StreamingContext.
Merge branch 'dev' of github.com/radlab/spark into dev
Compile fixes
Made minor changes to reduce compilation errors in Eclipse. Twirl stuff still does not compile in Eclipse.
Fixes to ShuffleFetcher
Make checkpoint interval configurable in WordCount2
Deserialize multi-get results in the caller's thread. This fixes an
issue with shared buffers with the KryoSerializer.
Replicate serialized blocks properly, without sharing a ByteBuffer.
Really fixed the replication-3 issue. The problem was a few buffers not being rewound.
WordCount tweaks
Added StateDStream, corresponding stateful stream operations, and testcases. Also refactored few PairDStreamFunctions methods.
Better output messages for streaming job duration
Bug fix
Bug fix
More block manager fixes
First work towards a RawInputDStream and a sender program for it.