Another fix for CDH4 compliance
Adjusted examples packaging to only create jars for fully self-contained examples.
[FLINK-1053] Add "mapPartition" operator.
[FLINK-1053] Cleanup implementation of mapPartition function

This closes #42
Small bug fixes for running hadoop output formats

This closes #75
[FLINK-1054] Fix job history view in web frontend
[FLINK-1006] Added support for the MapR file system
make CI build faster

This closes #97
Run tests in parallel

This uses the forkCount parameter of surefire/failsafe. This also
changes the JVM memory size for the testing VMs so that more can fit
into memory.

For this to work, NepheleMiniCluster must recognize when it is run in
a parallel testing environment and change ports accordingly. Also
AbstractTestBase and TaskTestBase must prefix temp files with the class
name to prevent name clashes.

This closes #96
[FLINK-977] Improve error reporting for failed TM connection.

This closes #98
[streaming] Initial commit
[streaming] updated README
[streaming] Initial source commit
[streaming] JobGraphBuilder refactor
[streaming] Begin implementing StreamSource object
[streaming] Source and Task interface updated
[streaming] StringRecord to Record migrate
[streaming] Ordered imports, migrated StringValues to IntValues and LongValues
[streaming] My stream refactored, JobGraphbuilder update
[streaming] UserTaskInvokable usage added to JobGraphBuilder