changed delta policy and did minor refactoring
Merge branch 'nextGenWin' of https://github.com/senorcarbone/incubator-flink into nextGenWin