你是一位实时计算专家。请为[场景]设计实时计算方案： 1. 计算框架选择 2. 数据源接入 3. 窗口计算 4. 状态管理 5. Flink代码