首页
问答库
知识库
教程库
标签
AI工具箱
登录
注册
投稿
在spark结构化流式java中节省偏移量
nkkqxpd9
于 2021-06-06
发布在
Kafka
关注(0)
|
答案(0)
|
浏览(212)
使用spark structured streaming进行批处理查询时,如何读取特定的批处理、处理它们并保存偏移量,以便作业的后续运行从第一次停止的位置开始消耗?
Java
apache-kafka
spark-structured-streaming
Offset
来源:
https://stackoverflow.com/questions/52104342/saving-offsets-in-spark-structured-streaming-java
关注
举报
暂无答案!
目前还没有任何答案,快来回答吧!
我来回答
相关问题
查看更多
热门标签
更多
Java
query
python
Node
开发语言
request
Util
数据库
Table
后端
算法
Logger
Message
Element
Parser
最新问答
更多
Python pillow/PIL无法识别对象“imagedraw”的属性“textsize”
回答(3)
发布于
5个月前
python-3.x ImportError:无法从“typing_extensions”导入名称“deprecated”
回答(2)
发布于
5个月前
python-3.x 我正尝试使用密码学对字典进行加密
回答(1)
发布于
5个月前
在Python的IDLE中导入audiolazy的问题
回答(1)
发布于
5个月前
如何将Python程序中的数据添加到Markdown?
回答(2)
发布于
5个月前
暂无答案!
目前还没有任何答案,快来回答吧!