spark读写kudu spark

package sparkUtilimport org.apache.kudu.spark.kudu.KuduContext import org.apache.spark.SparkConf import org.apache.spark.sql.SparkSessionobject SparkKudu { //kuduMasters and tableName val kuduMasters = "node1:7051" val tableName = "person"def main(args: Array[String]): Unit = { val conf = new SparkConf() conf.setAppName("SparkKudu ") conf.setMaster("local") val option = Map("kudu.master" -> kuduMasters, "kudu.table" -> tableName) val sparkSession = SparkSession.builder().config(conf).getOrCreate() val kc = new KuduContext(kuduMasters, sparkSession.sparkContext)//write and read kudu val DataFrame = sparkSession.read.format("org.apache.kudu.spark.kudu").options(option).load() kc.updateRows(DataFrame, tableName)sparkSession.close() } }

【spark读写kudu】

spark读写kudu

推荐阅读

凉血祛风糖浆的说明书

非师范学生当老师非师范生怎么当上老师

linux抓网络数据命令 linux网络抓包分析工具

什么是视频滤镜，视频滤镜原理

微信声音锁登录无法识别如何解决微信声音锁登录无法识别如何解决呢

黄芪水一个星期喝几次是合理的

圣诞语录短句简短圣诞语录短句简短给朋友

十条笑话:儿子喜欢上隔壁家女儿，我该怎么办?

关于电脑怎么同步微信视频号的信息

易拉罐吹跑车声音教程这么强大的操作

枯萎的玫瑰花瓣可以做什么

redis和数据库不一致时怎么解决 Redis和sql区别

天之蓝海之蓝梦之蓝洋河海之蓝酒价格表

心烦的时候怎么办

如何在云服务器上安装PHP？云服务器怎么安装php

安装辅材包括哪些安装辅材包括哪些东西

华为编程语言仓颉官网报名，谁创造了汉语

新产品上市的推广话术新品上市广告语怎么写

廖常初plc编程及应用，PLC编程及应用第3版廖常初课后答案

紫砂壶怎么选