如果 Bigtable 表和列族不存在，如何在 Dataflow 作业中创建它们
How to create Bigtable tables and column families in a Dataflow job if they doesn't exist
我有一个 Cloud Dataflow job，它将所有内容写入一个 table 和一个列族。如何修改此作业以写入可能存在或不存在的多个 table 和列族？例如，如果 table 或列族不存在，请创建一个然后写入它。
This 示例应该向您展示如何检查 table 是否存在，如果不存在则创建它。
该代码示例中的 Admin 接口也可用于获取 table (getTableDescriptor) 的列族，并在必要时创建一个 (addColumn ).
我有一个 Cloud Dataflow job，它将所有内容写入一个 table 和一个列族。如何修改此作业以写入可能存在或不存在的多个 table 和列族？例如，如果 table 或列族不存在，请创建一个然后写入它。
This 示例应该向您展示如何检查 table 是否存在，如果不存在则创建它。
该代码示例中的 Admin 接口也可用于获取 table (getTableDescriptor) 的列族，并在必要时创建一个 (addColumn ).