ApacheBeam的BigQueryIO(Java)无法将TIMESTAMP字段写入BigQuery--fasterxml.jacksonexception'typenotsupported”。
创始人
2024-09-05 11:01:07
0

这是因为Jackson库不支持将Java的java.sql.Timestamp类型映射到BigQuery的TIMESTAMP类型。解决此问题的解决方法是将java.sql.Timestamp转换为java.util.Date并写入BigQuery。下面是一个使用自定义转换器解决此问题的示例代码:

// 创建自定义转换器
public class TimestampToUtcDateConverter extends TableRowJsonConverter {
  private static final DateTimeFormatter FORMATTER =
      DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss.SSSSSS").withZoneUTC();

  @Override
  protected void setValue(
      FieldValueList row, String key, Object value, Schema.Field field) {
    Schema.Type fieldType = field.getType();

    if (Schema.Type.DATETIME.equals(fieldType)) {
      Timestamp timestampValue = (Timestamp) value;
      DateTime dateTime = new DateTime(timestampValue.getTime());
      row.set(key, FORMATTER.print(dateTime));
    } else {
      super.setValue(row, key, value, field);
    }
  }
}

// 使用自定义转换器将java.sql.Timestamp转换为java.util.Date
PCollection input = ...;
input.apply(
    BigQueryIO.writeTableRows()
        .to("my-dataset.my-table")
        .withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED)
        .withWriteDisposition(WriteDisposition.WRITE_APPEND)
        .withSchema(getTableSchema())
        .withJsonSchema(getJsonSchema())
        .withFormatFunction(
            (MyObject o) -> {
              TableRow row = new TableRow();
              row.set("timestampField", new Date(o.getTimestamp().getTime()));
              // 将java.sql.Timestamp转换为java.util.Date并在TableRow中进行设置
              ...
              return row;
            })
        .withCustomGcsTempLocation(StaticValueProvider.of("gs://my-bucket/tmp"))
        .withCustomConverter(Timestamp.class, new TimestampToUtcDateConverter()));

上面的示例代码假定存在名为'my-dataset.my-table”的BigQuery表,并且MyObject类具有名为'timestamp”的java.sql.Timestamp字段。在写入BigQuery时,我们使用自定义转换器将java.sql.Timestamp转换为java.util.Date,并将类似'2021-01-01 00:00:00.000000”这样的文字格式写入BigQuery。

相关内容

热门资讯

揭幕透视!pokemmo内置修... 揭幕透视!pokemmo内置修改器!确实真的是有辅助工具(详细教程)-哔哩哔哩1、进入到pokemm...
分享透视!epoker有透视吗... 分享透视!epoker有透视吗!都是有辅助工具(的确有挂)-哔哩哔哩epoker有透视吗是不是有人用...
解谜透视!红龙poker辅助器... 解谜透视!红龙poker辅助器免费观看!竟然真的有辅助教程(有挂猫腻)-哔哩哔哩1、完成红龙poke...
详细透视!德州圈脚本!总是是有... 详细透视!德州圈脚本!总是是有辅助app(真实有挂)-哔哩哔哩1、金币登录送、破产送、升级送、活动送...
有挂透视!德州局脚本!一贯一直... 有挂透视!德州局脚本!一贯一直总是有辅助教程(存在有挂)-哔哩哔哩德州局脚本能透视中分为三种模型:德...
关于透视!pokemmo脚本最... 您好,pokemmo脚本最新版这款游戏可以开挂的,确实是有挂的,需要了解加去威信【485275054...
有挂透视!哈糖大菠萝破解器!一... 有挂透视!哈糖大菠萝破解器!一贯一直都是有辅助神器(有挂教学)-哔哩哔哩1、哈糖大菠萝破解器破解器简...
了解透视!拱趴大菠萝挂哪里!果... 了解透视!拱趴大菠萝挂哪里!果然一直都是有辅助攻略(有挂细节)-哔哩哔哩1、很好的工具软件,可以解锁...
必备透视!扑克之星辅助!切实是... 必备透视!扑克之星辅助!切实是有辅助软件(有挂解惑)-哔哩哔哩一、扑克之星辅助游戏安装教程牌型概率发...
必备透视!sohoo竞技联盟辅... 必备透视!sohoo竞技联盟辅助器!总是是有辅助攻略(存在有挂)-哔哩哔哩1)sohoo竞技联盟辅助...