Re: 为什么在KeyedStream上进行任何transformation都会变回DataStream

2019-10-25 文章 Utopia
谢谢 2019年10月25日 +0800 17:01 Dian Fu ,写道: > 因为执行完transformation之后,不能保证一定还是KeyedStream。如果确实还是KeyedStream,可以通过DataStreamUtils.reinterpretAsKeyedStream,声明成KeyedStream,不会引入keyBy。 > > > 在 2019年10月25日,下午4:05,Utopia 写道: > > > > 大家好, > > > > KeyedStream 执行 transformation 以后不能变成 KeyedStream 吗,这样每次

Re: 为什么在KeyedStream上进行任何transformation都会变回DataStream

2019-10-25 文章 Dian Fu
因为执行完transformation之后,不能保证一定还是KeyedStream。如果确实还是KeyedStream,可以通过DataStreamUtils.reinterpretAsKeyedStream,声明成KeyedStream,不会引入keyBy。 > 在 2019年10月25日,下午4:05,Utopia 写道: > > 大家好, > > KeyedStream 执行 transformation 以后不能变成 KeyedStream 吗,这样每次 transformation 都要重新 > keyBy,这样不太符合直觉,写的也很冗余。 > > 谢谢~

为什么在KeyedStream上进行任何transformation都会变回DataStream

2019-10-25 文章 Utopia
大家好, KeyedStream 执行 transformation 以后不能变成 KeyedStream 吗,这样每次 transformation 都要重新 keyBy,这样不太符合直觉,写的也很冗余。 谢谢~