flink中的keyBy中的key

2021-04-12 15:55:16 浏览数 (1)

这个key是虚拟key,没有实体,所以不会返回。 其是从进来的流数据中选取的字段。 关键看这个虚拟key是什么类型。

代码语言:javascript复制
KeyedStream<Tuple3<String, String, Integer>, Tuple> keyedStream = map.keyBy(0);
keyedStream.print();
KeyedStream<Tuple3<String, String, Integer>, String> KeyedStream5 = map.keyBy(tuple -> tuple.f1);

我的博客即将同步至腾讯云 社区,邀请大家一同入驻:https://cloud.tencent.com/developer/support-plan?invite_code=3it8lnyw4zggs

0 人点赞