flink中使用lambda表达式实现allwindowfunction如何为其添加泛型

在使用Lambda表达式实现AllWindowFunction时，可以使用Java的泛型来指定输入和输出类型。例如，以下是一个使用Lambda表达式实现的AllWindowFunction，其输入和输出类型都为String：

AllWindowFunction<String, String, TimeWindow> function = (window, input, out) -> {
    String result = "";
    for (String str : input) {
        result += str;
    }
    out.collect(result);
};

在这个例子中，输入类型为String，输出类型也为String。如果要使用其他类型，只需要将泛型类型替换为相应的类型即可，例如：

AllWindowFunction<Integer, Double, TimeWindow> function = (window, input, out) -> {
    double sum = 0.0;
    for (int i : input) {
        sum += i;
    }
    out.collect(sum / input.size());
};

在这个例子中，输入类型为Integer，输出类型为Double。