Hi
flatmap????????????????????Keyedstream????keyby??????????????keyedstream?? Best, Yichao Yang ------------------ ???????? ------------------ ??????: "????????"<[email protected]>; ????????: 2020??6??10??(??????) ????7:18 ??????: "user-zh"<[email protected]>; ????: ????DataStreamUtils.reinterpretasKeyedStream?????? hi &nbsp; ??????????????????????????????key.??keyby, DataStream resStream =&nbsp; demoStream.keyBy(groupKeys) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .flatMap(new MyFlatmapFunction()) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .keyBy(groupKeys) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .process(new MyProcessFunction()) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .keyBy(groupKeys) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .timeWindow(Time.seconds(1)) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .aggregate(new MyAggFunction()) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .keyBy(groupKeys) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .timeWindow(Time.seconds(1)) &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; .process(new MyKeyProcessFunction()); ????????DataStreamUtils.reinterpretasKeyedStream?????????????????????????????????????? int[] groupKeys = new int[]{0,2,3}; DataStream proStream = DataStreamUtils.reinterpretAsKeyedStream(demoStream, new MyKeySelector2(groupKeys) ) // MyKeySelector2 ????????keySelector .flatMap(new MyFlatmapFunction()) ??????????????????????flatmap????????????????keyedstream ,??????????????????????????????????DataStreamUtils.reinterpretasKeyedStream
