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

推荐阅读

微信某—个人加密私聊微信私聊会被监控吗

常德鼎城区免费两癌筛查最新消息常德市两癌筛查免费医院

jquery制作菜单，用jquery做下拉菜单

英语学习机,英语听读机哪个品牌好

林内热水器运行开关不亮解决步骤热水器突然不亮了 ,试着这样弄一下

腐乳空心菜

震网源码分析,tomcat源码分析

如何删除视频的一段文字如何删除视频的一段，如何删除视频的一段音乐

最好的在线二维码生成器有哪些？

基督教讲道视频如何代祷

味精吃多了为什么会口渴？

汉服发片直播文案，穿汉服直播要讲什么

逝者安息生者如斯是什么意思是什么愿逝者安息生者如斯是什么意思

天力48112 天力星G1003D使用说明

薄荷茶能天天喝吗

金风送爽是哪个季节的成语金风送爽是属于哪个季节

学习笔记|【Kafka｜常用CLI】Topic管理

竹鼠养殖技巧，竹鼠养殖技巧和方法

吃鸡蛋的节气节气食俗之惊蛰为什么要吃鸡蛋

老实的近义词是什么老实的含义