flink根据每个省份的有效完成率（有效完成率=有效完成单数/接单总数）代码

假设我们有一个Flink的DataStream，每个元素包含如下字段：省份、接单数、完成单数。代码示例如下：

DataStream<Tuple3<String, Integer, Integer>> dataStream = ...; // 省份、接单数、完成单数

DataStream<Tuple2<String, Double>> resultStream = dataStream
        .keyBy(0) // 按省份分组
        .map(new MapFunction<Tuple3<String, Integer, Integer>, Tuple2<String, Double>>() {
            @Override
            public Tuple2<String, Double> map(Tuple3<String, Integer, Integer> value) throws Exception {
                double completionRate = value.f2 / (double) value.f1; // 计算有效完成率
                return Tuple2.of(value.f0, completionRate); // 返回省份和有效完成率
            }
        });

resultStream.print(); // 输出结果

上述代码中，我们首先按省份进行分组，然后使用`MapFunction`计算每个省份的有效完成率，并将省份和有效完成率组成一个二元组返回。最后，我们将结果打印出来。