started the expiry implementation for checkpoints
merged with master and finished the integration
added a missing passed parameter for expiry
skipping a test for now
Added the new stratify method. Merge commit '0e3fd23'
small code review change on the stratify method. Fixes #272
fixed #273 where input channels where not created properly because of a Scalaz bug
changed the groupWhen method to partitionWhen to avoid misunderstandings with the scalaz method
renamed partitionWhen to partition
set the compression to false for a DataSink unless it is explicitly specified
added a compatibility class using reflection to abstract over the differences between Hadoop v1 and v2
Merge branch 'master' into checkpoint-expiry
fixed the archiving policies of checkpoints
setting the number of reducers to 0 when there is no gbk and using the output channels to output values
updated specs2
using FiniteDuration on checkpoint expiryTime and added some doc
fixed the failing unit test
fixed a bug when checking the existence of a checkpoint
using the local mode in the REPL when hadoop is not installed. fixes #268
used a hash of the checkpoint path to create the bridgestore class name so that it is consistent between runs