DO NOT USE THIS INSTANCE FOR LIVE DATA!!!!
Remove countsPerPartition() method in blas/package.scala since Flink-3657 is now part of Flink 1.0.2 release.