边境的小盗贼_个人页

个人头像照片 边境的小盗贼
个人头像照片
0
3
0

个人介绍

暂无个人介绍

擅长的技术

获得更多能力
通用技术能力:

暂时未有相关通用技术能力~

云产品技术能力:

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息

2024年12月

正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2024-12-30

    Flink CDC中如果MySQL 字段设置了默认值,字段值为空时,捕获到的变更数据为默认值??

    已找到解决版本可以对cdc的数据自己转换格式Struct 类提供了 getWithoutDefault(String fieldName)函数,可以获取原始值。 public Object getWithoutDefault(String fieldName) { Field field = lookupField(fieldName); return values[field.index()]; } 我之前一直用的get(Field field)函数,原始值为空会使用默认值。 public Object get(Field field) { Object val = values[field.index()]; if (val == null && field.schema().defaultValue() != null) { val = field.schema().defaultValue(); } return val; }
    踩0 评论0
  • 回答了问题 2024-12-30

    Flink CDCmysql 的时候,发现 null 值,这个有方法解决吗?

    已有解决办法 自己转换数据即可 提供的有此类函数 可以看我的12.28号的提问
    踩0 评论0
  • 提交了问题 2024-12-28

    Flink CDC中如果MySQL 字段设置了默认值,字段值为空时,捕获到的变更数据为默认值??

正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息