spark中的println失效问题解决
我们知道,
spark中的println会被控制台忽略.
代码如下:
import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
import org.apache.spark.sql.functions._ // for lit(), first(), etc.
import org.apache.log4j.Logger
import org.apache.log4j.Levelobject RunIntro extends Serializable {def main(args: Array[String]): Unit = {prints(spark,"------------来看下这个复杂的SQL语句-----------------")val spark = SparkSession.builder.appName("Intro").config("spark.master", "local").getOrCreate();spark.sparkContext.setLogLevel("ERROR")}
def prints(spark:SparkSession,log:String) : Unit = {var rdd= spark.sparkContext.parallelize(List(log))rdd.collect().foreach(println)//Spark里面,必须两句话配合才能输出.
}}
实际项目的时候,把上面的prints函数拷贝到自己的工程里面,
然后一句:
prints(spark,"------------来看下这个复杂的SQL语句-----------------")
就行了.
spark中的println失效问题解决相关推荐
- 微信小程序在模板语法中使用indexOf失效问题解决办法
失效问题: 小程序的mastache语法不支持js的方法. 即在页面标签中,使用以下js方法无效: Object.keys() toString() indexOf() 解决办法-wxs: WXS(W ...
- asp.net 中Button按钮失效问题解决办法
在asp.net页面中,有时候Button按钮会失效,根据经验,导致整个问题发生一般有两种可能性: 一.页面中添加了验证控件,对于这种情况,需要对Button及其相关联的验证控件的Validation ...
- Spark SQL中出现 CROSS JOIN 问题解决
Spark SQL中出现 CROSS JOIN 问题解决 参考文章: (1)Spark SQL中出现 CROSS JOIN 问题解决 (2)https://www.cnblogs.com/yjd_hy ...
- nginx反向代理(proxy_pass)tomcat的过程中,session失效的问题解决
nginx反向代理(proxy_pass)tomcat的过程中,session失效的问题解决 参考文章: (1)nginx反向代理(proxy_pass)tomcat的过程中,session失效的问题 ...
- Intellij IDEA开发环境搭建,scala配置及打包,jar包在spark中的运行
1. Intellij IDEA 开发环境搭建 最近在学习scala,除需要编写scala程序外,同时还需要创建maven工程,打成Jar包,而Eclipse在这方面显得使用的不是那么方面,同时由于I ...
- Java查询spark中生成的文件_java+spark-sql查询excel
Spark官网下载Spark 下载Windows下Hadoop所需文件winutils.exe 同学们自己网上找找吧,这里就不上传了,其实该文件可有可无,报错也不影响Spark运行,强迫症可以下载,本 ...
- Spark中常用的算法
Spark中常用的算法: 3.2.1 分类算法 分类算法属于监督式学习,使用类标签已知的样本建立一个分类函数或分类模型,应用分类模型,能把数据库中的类标签未知的数据进行归类.分类在数据挖掘中是一项重要 ...
- spark中local模式与cluster模式使用场景_Spark 知识点 ( 架构 RDD Task )
1. Spark介绍 Apache Spark是一个围绕速度.易用性和复杂分析构建的大数据处理框架,最初在2009年由加州大学伯克利分校的AMPLab开发,并于2010年成为Apache的开源项目之一 ...
- 在Spark中自定义Kryo序列化输入输出API(转)
原文链接:在Spark中自定义Kryo序列化输入输出API 在Spark中内置支持两种系列化格式:(1).Java serialization:(2).Kryo serialization.在默认情况 ...
最新文章
- LinkedList源码剖析
- python快速上手 让繁琐工作自动化 英文版_入门python:《Python编程快速上手让繁琐工作自动化》中英文PDF+代码...
- 【学习笔记】 IPv4地址、NAT与子网掩码、子网划分
- 【VBS】网页脚本的放置位置与载入时机
- macos通过brew安装后端开发工具
- SimpleDateFormat类format方法和parse方法的使用
- python二元函数图像在线绘制_numpy,matplotlib
- MaxCompute SQL
- java计算机毕业设计房屋租赁管理系统源码+系统+lw+数据库+调试运行
- 水瓶座的女人,生活中不只需要代码(转帖)
- jupyter lab R
- 在java中如何输入角度_在Java中获取角度的反余弦
- 数学中说的线性关系线性是什么意思?
- 上饶服务器租用 游戏服务器如何选择?
- c语言发送短信,c语言短信.doc
- bootstraptable 超多列_Bootstrap mergeCells合并单元格(多列)
- A Game of Thrones(55)
- 集美大学计算机毕业论文,集美大学毕业设计模板-
- Oracle VM VirtualBox安装Win10系统
- 菜小白聊聊开源和开源协议
热门文章
- VB winform自动更新 笔记
- 查看SQL SERVER 加密存储过程,函数,触发器,视图
- JS原生 实现图片懒加载
- java程序解析perl文件_如何从shell脚本执行perl文件
- ES6结构赋值的用途
- 两种方法用于检查传入的数字是否为整数
- VTK:libvtkGUISupportQt-6.3.so.1: cannot open shared object
- 点云处理软件Pointscene
- 理解DDoS防护本质:基于资源较量和规则过滤的智能化系统
- python绝技 — 使用PyGeoIP关联IP地址和物理位置