辛友个人主页

@zhaochengxuyuan1

辛友

2023-01-12 11:36:59 加入 DevPress

简介

该用户还未填写简介

擅长的技术栈

未填写擅长的技术栈

可提供的服务

暂无可提供的服务

flink消费kafka历史数据开窗计算数据丢失问题追踪记录

flink消费kafka数据开窗丢失数据问题

#kafka #flink #大数据

spark 二次排序两种方法（scala）

排序数据：aa 34bb 24cc 83aa 53cc 12aa 47bb 35aa 21cc 64bb 73第一种方法是用spark中的sortBy方法：首先将数据处理成（“aa”，34）的格式；然后使用sortBy算子进行排序；/*** 二次排序使用sortBy*/rdd.map(a => (a.split(" ")(0),a.split(" &qu

#spark

M1芯片MacBook Pro解决snappy-java的FAILED_TO_LOAD_NATIVE_LIBRARY问题

#java #开发语言

到底了