创建一个数据库，包括四个表：学生表（Student）、课程表（Course）、成绩表（Score）以及教师信息表（Teacher）。四个表的结构分别如表1-1的表（一）~表（四）所示，数据如表1-2的表…表（一）Student (学生表)属性名数据类型可否为空含 义Snovarchar (20)否学号Snamevarchar (20)否学生姓名Ssexvarchar ...

两种查询风格1、准备工作读取文件并转换为DataFrame或DataSetval lineRDD= sc.textFile(“hdfs://node01:8020/person.txt”).map(_.split(" "))case class Person(id:Int, name:String, age:Int)val personRDD = lineRDD.map(x =>...

Flink 简介1.1 Flink 的引入这几年大数据的飞速发展，出现了很多热门的开源社区，其中著名的有 Hadoop、Storm， 以及后来的 Spark，他们都有着各自专注的应用场景。Spark 掀开了内存计算的先河，也以 内存为赌注，赢得了内存计算的飞速发展。 Spark 的火热或多或少的掩盖了其他分布式计 算的系统身影。就像 Flink，也就在这个时候默默的发展着。 在国外一些社区，有很多

SELECTt1.a, t1.b, t1.c, t2.nmFROMt1LEFT JOINt2ON t1.id = t2.aidWHEREt1.id is nullOR SUBSTR(t1.b,4) != t2.nm

什么是Spark基于内存的，用于大规模数据处理（离线计算、实时计算、快速查询（交互式查询））的统一分析引擎。Spark特点快：Spark计算速度是MapReduce计算速度的10-100倍易用：（算法多）MR支持1种计算模型，Spsark支持更多的算模型。通用：Spark 能够进行离线计算、交互式查询（快速查询）、实时计算、机器学习、图计算等兼容性：Spark支持大数据中的Y...

liunx集群(三台),scp远程文件拷贝,ssh远程登陆~~ 集群(三台)克隆虚拟机2.更改新增系统的mac地址3.更改网卡信息 (setup)重启系统生效reboot三台机器 关闭防火墙内网环境 安全性比较高, 防火墙开启会影响效率, 所以 关闭防火墙三台机器执行以下命令（root用户来执行）三台机器关闭selinux三台机器更改主机名重...

准备新节点第一步：复制一台新的虚拟机出来将我们纯净的虚拟机复制一台出来，作为我们新的节点第二步：修改mac地址以及IP地址修改mac地址命令vim /etc/udev/rules.d/70-persistent-net.rules修改ip地址命令vim /etc/sysconfig/network-scripts/ifcfg-eth0第三步：关闭防火墙，关闭selinux关闭...

常用API1、Date类2、DateFormat类3、Calendar类4、System类5、Math类1.Date1.1概念Date是日期类，表示一个的瞬间。精确到毫秒。1.2、常见构造public static void main(String[] args) {Date d1 = new Date();// 获取当前时刻的date对象进行打印System....

常用API1.API简介1.1API概念API全名application(应用) programming(程序) interface(接口)API是应用程序编程接口Java APIJava API就是sun公司提供给我们使用的类，这些类将底层的实现封装了起来，我们不需要关心这些类是如何实现的，只需要学习这些类如何使用，为使用提供的帮助文档。文档注释在JDK中有src.zip...

常用API1.基本类型包装类1.1概念由于基本类型是内置的数据类型，与使用class定义的自定义类型略有不同，不能调用方法完成强大的功能。为了使基本数据类型代表的数据使用起来更方便，统一面向对象的思想，Java设计了基本类型包装类，即每一种基本类型都对应一种引用类型的包装数据类型。基本类型包装类即为基本类型套上一个引用类型的盒子。除去整型与字符型，其他基本数据类型将首字母大写即为包装数据...