Flink keyby数据倾斜问题

[chanamper]

Dear All,
    大家好，请教一下。目前针对Java Api的方式，对于Flink keyby情况存在key数据倾斜有啥实现优化思路吗？看官方文档目前在table 
api和sql层面，有Minibatch Aggregation和Local Global Aggregation方式的实现，针对Java 
Api的方式有啥办法可以达到local global aggregation的效果吗？
      多谢！