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

[Utopia]

大家好，

KeyedStream 执行 transformation 以后不能变成 KeyedStream 吗，这样每次 transformation 都要重新 keyBy，这样不太符合直觉，写的也很冗余。

谢谢～

[Dian Fu]

因为执行完transformation之后，不能保证一定还是KeyedStream。如果确实还是KeyedStream，可以通过DataStreamUtils.reinterpretAsKeyedStream，声明成KeyedStream，不会引入keyBy。

> 在 2019年10月25日，下午4:05，Utopia <[hidden email]> 写道：
>
> 大家好，
>
> KeyedStream 执行 transformation 以后不能变成 KeyedStream 吗，这样每次 transformation 都要重新 keyBy，这样不太符合直觉，写的也很冗余。
>
> 谢谢～

[Utopia]

谢谢🙏
2019年10月25日 +0800 17:01 Dian Fu <[hidden email]>，写道：

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