$ loading_
让 AI 管理 Apache Beam 数据管道并跨多种运行器执行与调度。
复制安装指令，让 AI 自动完成配置 · 推荐新手
"Apache Beam MCP Server" 暂无可直接复制的安装信息，请查看页面文档或源码仓库。
请连接 Apache Beam MCP Server，列出当前支持的运行器（如 Flink、Spark、Dataflow、Direct）以及每种运行器可执行的管道管理操作，并用表格总结差异。
返回支持的运行器清单、各自能力说明，以及便于选择的对比表。
请通过 Apache Beam MCP Server 创建一个 Beam 管道：读取指定输入数据，完成清洗、字段映射和聚合统计，然后在 Dataflow 运行器上执行，并返回任务状态与关键配置。
生成管道执行方案、运行配置、提交结果与任务状态摘要。
我有一个 Apache Beam 管道在 Direct 运行正常，但切换到 Flink 后失败。请通过 Apache Beam MCP Server 检查作业状态、错误信息和配置差异，并给出修复建议。
输出失败原因分析、配置差异定位，以及可执行的修复建议。
安全只读连接 BigQuery，让 AI 进行数据查询与分析洞察
让 AI 通过标准接口查询并分析 Prometheus 监控指标，辅助排障与运维决策。
连接 BigQuery，供 AI 检查数据表结构并执行查询分析。
通过自然语言查询结构化数据，让 AI 无需 SQL 或 API 知识也能回答问题。
为 Spark 提供查询计划与目录信息，辅助优化查询并发现数据。
用自然语言管理 Apache Airflow 工作流，监控 DAG、控制任务并调整配置。