Flink 1.10 Local Aggregate问题

[chanamper]

Dear All，
        请教一下，Flink 1.10版本中Java Api如何实现Local Aggregate的功能呢？数据存在较大的倾斜，想在keyby前进行一次local aggregate， 看了下在https://cwiki.apache.org/confluence/display/FLINK/FLIP-44%3A+Support+Local+Aggregation+in+Flink有计划实现localKeyBy()方法， flink 1.10 java api中还没发现对应的localKeyBy方法。请问下，目前Java API对这种数据倾斜有啥好的处理思路吗？另外FLIP-44可能预计啥时候能够使用呢？