apache-beam - Apache Beam 管道执行
问题描述
我已经实现了一个基于 Java API 的管道,它从数据源读取数据,应用一些转换并将输出写入数据库。我使用本地运行器测试了管道,它执行时没有任何错误。我当前的部署没有 Kubernetes 或基于云的设置。我对管道部署方面有一些疑问。
- 是否可以在没有集群设置的情况下使用 Flink Runner 在本地执行模式下从其他 Java 程序启动管道?还有可能监控管道执行吗?
- 我需要将我的管道应用程序打包为 docker 容器吗?
解决方案
推荐阅读
- google-apps-script - 使用 Google Apps 脚本创建共享云端硬盘(以前称为团队云端硬盘)
- angular - 以角度编写的单词插件 - 查找并选择文本
- mysql - 如何在sql where子句中实现'if not-then'之类的东西
- php - 插入数据后选项刷新
- android - GeoPoint 不允许存储在 Room 中
- ios - 如何根据内容自动设置自定义 UIView 宽度?
- python - pypyodbc 不提交
- mvvm - MVVM 新鲜与 MVVM 轻 xamarin 形式
- python - 如何强制 Python 3 使用单引号输出字符串?
- wpf - winforms 到 WPF Datagridview 和 datagrid