BigQueryIO - 只有在第一天创建表格,即使设置了CreateDisposition.CREATE_IF_NEEDED。
创始人
2024-12-12 15:00:07
0

解决上述问题的一种方法是使用BigQueryIO.Write.withSchema方法来指定表格的模式,并使用BigQueryIO.Write.withCreateDisposition方法将创建模式设置为BigQueryIO.Write.CreateDisposition.CREATE_IF_NEEDED。下面是一个示例代码:

PCollection rows = ... // 构建要写入BigQuery的数据

String tableName = "project_id:dataset.table";
TableSchema schema = new TableSchema();
schema.setFields(Arrays.asList(
    new TableFieldSchema().setName("field1").setType("STRING"),
    new TableFieldSchema().setName("field2").setType("INTEGER"),
    // 添加其他字段...
));

rows.apply(BigQueryIO.writeTableRows()
    .to(tableName)
    .withSchema(schema)
    .withCreateDisposition(BigQueryIO.Write.CreateDisposition.CREATE_IF_NEEDED));

在上面的代码中,我们使用BigQueryIO.writeTableRows方法将数据写入BigQuery表格。我们通过to方法指定了要写入的表格名称,并通过withSchema方法指定了表格的模式。最后,我们使用withCreateDisposition方法将创建模式设置为CREATE_IF_NEEDED,这样即使表格已经存在,也会在第一天创建表格。

请注意,上面的代码是使用Java SDK编写的示例,如果使用其他编程语言,代码可能会有所不同,但概念和解决方法相同。

相关内容

热门资讯

5分钟详情!一起宁德麻将钓蟹,... WePoker透视辅助版本稳定性对比与推荐‌:5分钟详情!一起宁德麻将钓蟹,智星德州菠萝app下载(...
九分钟总结!财神十三张输赢概率... 九分钟总结!财神十三张输赢概率,wepoke透明挂辅助(详细透视辅助器教程);玩家必备必赢加哟《13...
5分钟总结!永州扯胡子到底有没... 5分钟总结!永州扯胡子到底有没有外 挂,wpk微扑克真的有辅助插件(详细透视辅助黑科技教程);实战中...
3分钟教学!非常麻将发牌规律,... 1、3分钟教学!非常麻将发牌规律,aa扑克软件(详细透视辅助挂教程)。2、非常麻将发牌规律透视辅助简...
2分钟教程!中至棋牌麻将,we... 中至棋牌麻将赢率提升策略‌;2分钟教程!中至棋牌麻将,wepoke系统(详细透视辅助脚本教程);详细...
8分钟透明!丽水都莱罗松,aa... 8分钟透明!丽水都莱罗松,aapoker有猫腻(详细透视辅助挂教程)准备好在丽水都莱罗松 ia的高塔...
9分钟总结!白金岛放炮罚有挂吗... 9分钟总结!白金岛放炮罚有挂吗,红龙扑克是真正规的(详细透视辅助软件教程) 科技详细教程;75744...
八分钟教程!广西老友玩游戏辅助... 八分钟教程!广西老友玩游戏辅助器,德扑ai软件(详细透视辅助app教程);广西老友玩游戏辅助器软件透...
七分钟教程!多乐跑胡子有挂吗,... 七分钟教程!多乐跑胡子有挂吗,德扑之星真的有辅(详细透视辅助黑科技教程);多乐跑胡子有挂吗软件透明挂...
7分钟黑科技!微信斗地主小程序... 7分钟黑科技!微信斗地主小程序有挂吗,德州app辅助器(详细透视辅助工具教程)是一款可以让一直输的玩...