OwenLi
Results
2
issues of
OwenLi
我尝试把scala 源代码拷贝到我的项目里依然说找不到Provider类
我查看了很多文章,比如以前的直接拿到RDD的offsetRange属性等,但是往往在watermark情况下,我们都是转换过后的Dataset了,请问这种情况我们如何保证或者说如何自维护spark structured streaming当前清洗完的数据的最新的offset?
OwenLi
我尝试把scala 源代码拷贝到我的项目里依然说找不到Provider类
我查看了很多文章,比如以前的直接拿到RDD的offsetRange属性等,但是往往在watermark情况下,我们都是转换过后的Dataset了,请问这种情况我们如何保证或者说如何自维护spark structured streaming当前清洗完的数据的最新的offset?