边境的小盗贼_个人页
边境的小盗贼
文章
0
问答
3
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
暂无更多信息
-
回答了问题
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; }赞422 踩0 评论0 -
回答了问题
2024-12-30
Flink CDCmysql 的时候，发现 null 值，这个有方法解决吗？
已有解决办法 自己转换数据即可 提供的有此类函数 可以看我的12.28号的提问赞0 踩0 评论0 -
提交了问题
2024-12-28
Flink CDC中如果MySQL 字段设置了默认值，字段值为空时，捕获到的变更数据为默认值？？
滑动查看更多
暂无更多信息