如何在数据流作业中创建不存在的Bigtable表和列族

import com.google.cloud.bigtable.admin.v2.BigtableTableAdminClient;
import com.google.cloud.bigtable.admin.v2.models.CreateTableRequest;
import com.google.cloud.bigtable.admin.v2.models.CreateTableRequest.Split;
import com.google.cloud.bigtable.admin.v2.models.ColumnFamily;
import com.google.cloud.bigtable.admin.v2.models.CreateTableResponse;

public class CreateTableExample {
  public static void main(String[] args) {
    String projectId = "your-project-id";
    String instanceId = "your-instance-id";
    String tableId = "your-table-id";
    String columnFamilyId = "your-column-family-id";

    try (BigtableTableAdminClient adminClient = BigtableTableAdminClient.create(projectId, instanceId)) {
      // 创建表
      CreateTableRequest createTableRequest = CreateTableRequest.of(tableId).addFamily(columnFamilyId);
      CreateTableResponse createTableResponse = adminClient.createTable(createTableRequest);
      System.out.println("Table created: " + createTableResponse.getName());

      // 创建列族
      ColumnFamily columnFamily = ColumnFamily.of(columnFamilyId);
      adminClient.createColumnFamily(tableId, columnFamily);
      System.out.println("Column family created: " + columnFamily.getId());
    } catch (Exception e) {
      System.out.println("Error creating table or column family: " + e.getMessage());
    }
  }
}