Changed task shutdown logic
Merged experimental dataset and distributed environment code. Bug Fixes. Code Formatting...
Changed to kryo 3.0.0, now using unsafe, Changed some names.
minor bug fix
Improved tests
All dataflow tests in a JUnit suite