自定义博客皮肤VIP专享

*博客头图：

点击选择上传的图片

格式为PNG、JPG，宽度*高度大于1920*100像素，不超过2MB，主视觉建议放在右侧，请参照线上博客头图

请上传大于1920*100像素的图片！

博客底图：

点击选择上传的图片

图片格式为PNG、JPG，不超过1MB，可上下左右平铺至整个背景

栏目图：

点击选择上传的图片

图片格式为PNG、JPG，图片宽度*高度为300*38像素，不超过0.5MB

主标题颜色：

RGB颜色，例如：#AFAFAF

Hover：

RGB颜色，例如：#AFAFAF

副标题颜色：

RGB颜色，例如：#AFAFAF

预览取消提交

自定义博客皮肤

lck_csdn的博客

“承续缘”的成长纪录片

博客等级

码龄5年

关注

私信

使用dataX遇到的坑
楚不复: 感谢大佬！终于解决了！
Flink SQL 自定义 Connector
还行吧681: 你好，现在mqttx已经变成了v5，但是我看阿里云里面没有v5的1.9.10版本应该如何使用啊
ClickHouse性能情况以及相关优化
东来东往2024: 稀疏索引也是有最左匹配原则的吧
数据治理之标签管理（五）-标签功能需求
CSDN-Ada助手: 推荐 MySQL入门技能树：https://edu.csdn.net/skill/mysql?utm_source=AI_act_mysql
Flink连接Hbase
//承续缘_纪录片: 查询hbase不能使用scan（查询不到的情况会查询超时导致任务失败），需要使用get（查询不到返回空值） [code=java] public void asyncInvoke(T input, ResultFuture<T> resultFuture) throws Exception { Get get = new Get(Bytes.toBytes(getKey(input))); Result rs = table.get(get); for (Cell cell : rs.rawCells()) { String column = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()); String value = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); BeanUtils.setProperty(input, column, value); } resultFuture.complete(Collections.singletonList(input)); } [/code]

关注

文章平均质量分 95

数据湖开发流程

关注数：文章数：2 文章阅读量：1236 文章收藏量：5

这个作者很懒，什么都没留下…

展开

Iceberg删除过期snapshots、老的metadata files、孤立的文件，合并data files和manifests