240 发简信
IP属地:上海
  • 因为redis是单线程的,所以操作这个AtmoicLong的时候,是不是不需要加锁?

    Flink基于RoaringBitmap的精确去重方案

    在Flink实时统计中,提到去重,我能想到比较流行的几种方式: 布隆过滤器 - 非精确去重,精度可以配置,但精度越高,需要的开销就越大。主流的框架可以使用guava的实现,或...

  • 老师,求问一下,structured streaming 怎么解决程序更新重启,历史状态数据的维护?有什么好的思路可以提点一下吗?

    Structured Streaming如何实现Parquet存储目录按时间分区

    缘由 StreamingPro现在支持以SQL脚本的形式写Structured Streaming流式程序了: mlsql-stream。不过期间遇到个问题,我希望按天进行分...