热门标签
热门文章
- 1Scala编程基础2：函数、递归、异常
- 2Python+Django基于python的寻人失物失物招领系统
- 3【华为OD机考 统一考试机试C卷】最多购买宝石数目 （Java题解）
- 4智能车室内光电组ROS-2020—— 创建工作空间以及移植比赛模型文件_ubuntu 智能车比赛修改工作空间名称
- 5使用keras处理深度学习中的回归问题——波士顿房价预测_keras 模型的回归评价指标
- 6Ubuntu 22.04.3安装kubernetes v1.26.3_ubuntu--desktop-amd64
- 7java中ClassCastException类型转换异常（解决教程详解）_classcastexception 类型转换异常 java_java.lang.classcastexception: class com.sky.result
- 8做一个微信小程序多少钱？
- 9最好的商业模式_切高端客户背后的原理
- 10有趣的算法问题11——X的平方根（二分查找法）_随机算法求平方根
当前位置: article > 正文
flink sink数据到elasticsearch(scala&java)_sink写入es的scala代码
作者：我家自动化 | 2024-05-22 04:36:16
赞
踩
sink写入es的scala代码
代码参考了 zhisheng的java http://www.54tianzhisheng.cn/2018/12/30/Flink-ElasticSearch-Sink/ 以及同事的scala，在此说明一下
java 有add和upsert操作 upsert操作是根据id来判断是添加还是更新，add是无条件的追加
scala只有upsert操作
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家自动化/article/detail/606322
推荐阅读
相关标签
