- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
Apache Beam Java SDK 有一个 DynamicDestinations允许根据输入元素写入不同的大查询表的类。我在 Python SDK 中看不到任何看起来相同的东西。是否有一些类允许写入 Python SDK 中动态选择的目标表?
最佳答案
Apache Beam Python SDK 在功能多样性方面仍不如 Java SDK 先进,因此您确实可能会看到一些缺失的功能,这些功能仍然仅在 Java SDK 中可用。
据我所知,根据我能找到的 Python SDK Beam's BigQuery IO documentation ,目前没有可用于指定动态 BigQuery 目标的类,Java SDK 提供的类 (Dynamic Destinations in Java SDK)。
我建议您在 Apache Beam Jira issue tracker 中提交一个新问题作为功能请求解释为什么这个功能会很好地添加到 Python SDK 中,希望开发人员也会考虑这个选项。
关于python - Apache Beam DynamicDestinations Python 等价物,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50141318/
Apache Beam Java SDK 有一个 DynamicDestinations允许根据输入元素写入不同的大查询表的类。我在 Python SDK 中看不到任何看起来相同的东西。是否有一些类允
我的工作流程:KAFKA -> 数据流流 -> BigQuery 鉴于低延迟对我来说并不重要,我使用 FILE_LOADS 来降低成本。我将 BigQueryIO.Write 与 DynamicDes
我是一名优秀的程序员,十分优秀!