Hequn Cheng created FLINK-10476: ----------------------------------- Summary: Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api Key: FLINK-10476 URL: https://issues.apache.org/jira/browse/FLINK-10476 Project: Flink Issue Type: Improvement Components: Table API & SQL Reporter: Hequn Cheng Assignee: Hequn Cheng
Since KeyedStream.process(ProcessFunction func) is deprecated, we should change related ProcessFunction to KeyedProcessFunction in Sql/Table-api, for example {{ProcessFunctionWithCleanupState}} extends {{KeyedProcessFunction}} instead of {{ProcessFunction}}. -- This message was sent by Atlassian JIRA (v7.6.3#76005)