Я долго пытался настроить приложение flink, которое создает Datastream<Tuple3<Integer, java.sql.Time, Double>> из CSV-файла. Все столбцы в этом файле (столбцы ID, dateTime and Result) являются строковыми, но их следует преобразовать в целые, java.sql.Time и Double. Другая вещь, которую я хочу, - это создавать падающие окна с данными за день и усреднять значения столбца result в этом окне. Проблема в том, что я не знаю точный синтаксис для него. Смотрите мой код ниже, что я пытался. В последней части у меня есть сумма (2), но я хочу рассчитать среднее значение для окон. Я не видел в функции для этого в документации. Нужно ли самому писать метод для этого?
DataStream<Tuple3<String, java.sql.Time>> dataStream = env
.readfile(path)
.map()
.keyBy(0)
.timeWindow(Time.days(1));