A Flink streaming application that continuously monitors a CSV file for updates, processes new records in real-time, groups them by profile_id, and computes average amounts over a 30-day sliding ...