这在当前的BigqueryIO连接器中是不可能的。从这里存在的连接器的github链接中，您将观察到，对于您的代码StreamingWriteFn，表创建过程是在getOrCreateTable中完成的，这在finishBundle中调用。有一个createdTables的映射被维护，在finishBundle中，如果表不存在，则会创建它，一旦它存在并存储在hashmap中，它就不会重新创建，如下所示：-

    public TableReference getOrCreateTable(BigQueryOptions options, String tableSpec)
        throws IOException {
      TableReference tableReference = parseTableSpec(tableSpec);
      if (!createdTables.contains(tableSpec)) {
        synchronized (createdTables) {
          // Another thread may have succeeded in creating the table in the meanwhile, so
          // check again. This check isn't needed for correctness, but we add it to prevent
          // every thread from attempting a create and overwhelming our BigQuery quota.
          if (!createdTables.contains(tableSpec)) {
            TableSchema tableSchema = JSON_FACTORY.fromString(jsonTableSchema, TableSchema.class);
            Bigquery client = Transport.newBigQueryClient(options).build();
            BigQueryTableInserter inserter = new BigQueryTableInserter(client);
            inserter.getOrCreateTable(tableReference, WriteDisposition.WRITE_APPEND,
                CreateDisposition.CREATE_IF_NEEDED, tableSchema);
            createdTables.add(tableSpec);
          }
        }
      }
      return tableReference;
    }

为了满足您的要求，您可能必须维护自己的BigqueryIO，其中您不执行此特定检查

if (!createdTables.contains(tableSpec)) {

然而，更重要的问题是为什么表会在生产系统中被删除？这个问题应该得到解决，而不是尝试从数据流重新创建表。