标签：export 后台 技术分享 class use not mongod data 地址
进入官网下载地址 ,下载完整tar包.
tar zxvf zeppelin-0.7.3.tgz
新建配置文件
cp zeppelin-env.sh.template zeppelin-env.sh
修改配置文件
vi zeppelin-env.sh
# 设置java home 路径
export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.141-1.b16.el7_3.x86_64/jre
# 设置spark master 地址
export MASTER=spark://10.100.12.16:7077
# 设置spark home 路径
export SPARK_HOME=/opt/spark/
# 设置spark mongodb connector, 注意：这里用的是2.2.2版本
export SPARK_SUBMIT_OPTIONS="--packages org.mongodb.spark:mongo-spark-connector_2.11:2.2.2"
bin/zeppelin-daemon.sh start
7.写scala 查询代码
import com.mongodb.spark.config.ReadConfig import com.mongodb.spark.sql._ val config = sqlContext.sparkContext.getConf .set("spark.mongodb.keep_alive_ms", "15000") .set("spark.mongodb.input.uri", "mongodb://10.100.12.14:27017") .set("spark.mongodb.input.database", "bi") .set("spark.mongodb.input.collection", "userGroupMapping") val readConfig = ReadConfig(config) val objUserGroupMapping = sqlContext.read .format("com.mongodb.spark.sql") .mongo(readConfig) objUserGroupMapping.printSchema() val tbUserGroupMapping=objUserGroupMapping.toDF() tbUserGroupMapping.registerTempTable("userGroupMapping")
在zepplin 使用spark sql 查询mongodb的数据
标签：export 后台 技术分享 class use not mongod data 地址
原文地址：https://www.cnblogs.com/chengjunhao/p/8981695.html
