hi: flink keyby()时能否获取到subTask的编号,根据编号分组,让上游数据可以继续保持原有的数据依然在同一个subTask中进行后续计算。 在AbstractRichFunction类中this.getRuntimeContext().getIndexOfThisSubtask()可以获取编号,但是keyby()的KeySelector类中没有getRuntimeContext()方法。
- 关于keyby()如何保留原并行度的问题 junjie.m...@goupwith.com
- Re: 关于keyby()如何保留原并行度的问题 r pp
- Re: Re: 关于keyby()如何保留原并行度的问题 junjie.m...@goupwith.com
- Re:Re: Re: 关于keyby()如何保留原并行度的问题 haishui