Apache Zeppelin可以使用由另一个应用程序创建的Dataset<Row>吗?
创始人
2024-09-05 02:30:33
0

是的,Apache Zeppelin可以使用由另一个应用程序创建的Dataset。以下是一个使用Spark和Zeppelin的示例:

  1. 在应用程序中创建一个Dataset
import org.apache.spark.sql.{SparkSession, Dataset}

val spark = SparkSession.builder()
  .appName("Example App")
  .getOrCreate()

val data: Seq[(String, Int)] = Seq(("Alice", 25), ("Bob", 30), ("Charlie", 35))
val df = spark.createDataFrame(data).toDF("Name", "Age")

// 将DataFrame转换为Dataset
val dataset: Dataset[Row] = df.as("dataset")
  1. 在Zeppelin中使用该Dataset
%spark
// 在Zeppelin中,可以使用%spark魔法命令来访问SparkSession对象

// 创建一个新的DataFrame
val newData: Seq[(String, Int)] = Seq(("Dave", 40), ("Eve", 45))
val newDF = spark.createDataFrame(newData).toDF("Name", "Age")

// 将DataFrame转换为Dataset
val newDataset: Dataset[Row] = newDF.as("newDataset")

// 使用先前创建的Dataset
dataset.show()

// 使用新创建的Dataset
newDataset.show()

通过上述代码示例,您可以在Zeppelin中使用由另一个应用程序创建的Dataset。请注意,在Zeppelin中使用%spark魔法命令可以访问SparkSession对象,并使用先前创建的Dataset进行操作。

相关内容

热门资讯

一分钟教你!潮友辅助开挂,wp... 一分钟教你!潮友辅助开挂,wpk系统是否存在作弊行为,攻略教程(有挂技巧);潮友辅助开挂软件透明挂是...
玩家必看秘籍!奇迹陕西靖边打锅... 玩家必看秘籍!奇迹陕西靖边打锅子辅助,wpk透视辅助靠谱吗,教你攻略(有挂详细)是一款可以让一直输的...
科技通报!七千在线辅助,德州之... 科技通报!七千在线辅助,德州之星扫描器,教你攻略(有挂解密);1、点击下载安装,七千在线辅助插件透视...
新手必备!欢乐情怀辅助器,红龙... 新手必备!欢乐情怀辅助器,红龙poker作弊指令,微扑克教程(有挂解惑);欢乐情怀辅助器软件透明挂是...
玩家必看!吉祥填大坑脚本,xp... 玩家必看!吉祥填大坑脚本,xpoker怎么作弊,黑科技教程(有挂实锤);大家肯定在之前吉祥填大坑脚本...
最新技巧!天天开心王国有没有挂... 您好,天天开心王国有没有挂这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩...
一分钟秒懂!琼崖海南麻将辅助器... 一分钟秒懂!琼崖海南麻将辅助器,WePoKer辅助器,玩家教程(有挂教程);一分钟秒懂!琼崖海南麻将...
2分钟细说!微信小程序微乐家乡... 2分钟细说!微信小程序微乐家乡辅助器,hhpoker底牌透视脚本,必胜教程(果真有挂);1、德州微信...
分享认知!上饶辅助设备出租,w... 分享认知!上饶辅助设备出租,wepoker公共底牌,可靠技巧(确实有挂);1、让任何用户在无需AI插...
必备科技!天蝎辅助,hhpok... 必备科技!天蝎辅助,hhpoker怎么破解,分享教程(有挂神器)是一款可以让一直输的玩家,快速成为一...