Flink CE组模式API