方法一:在数据库中若是两张表中共同字段一个非空一个为NULL,可以通过sql语句进行合并: coalesce(t1.region_code,t2.region_code) as REGIONID 方法二:粗略写了个算法,也没有进行算法优化,仅供参考。 /// <param name="dt1">要合 ...
分类:
其他好文 时间:
2017-09-04 20:42:22
阅读次数:
211
RDD.getNumPartitions()方法可以获得一个RDD分区数量, 1、默认由文件读取的话,本地文件会进行shuffle,hdfs文件默认会按照dfs分片来设定。 2、计算生成后,默认会按照executor-number*executor-cores来分片,也就是spark默认按照总工作核 ...
分类:
其他好文 时间:
2017-07-27 20:24:54
阅读次数:
238
字符函数CONCAT 连接字符串SUBSTR 截取字符串LENGTH 打印字符串长度INSTR 索引位置 (indexOf) LPAD | RPAD 左右添加字符TRIM 删除两边字符或空格REPLACE 替换某个字符LOWER 转成小写UPPER 转成大写INITCAP 首字母大写数字函数ROUN ...
分类:
其他好文 时间:
2017-07-26 21:46:50
阅读次数:
152
select * from EMP where ENAME ='SMITH'; select ename || ' is a ' || job from emp; select distinct empno from emp; select * from emp where COMM>SAL; se... ...
分类:
其他好文 时间:
2017-07-17 13:19:30
阅读次数:
201
coalesce(expr1,expr2,expr3...) 直到找到一个非null值返回,右边的表达式则不参与运算;若所有为null,返回null. eg:判断json是否包含某属性,若无,则取默认值。 testdb=# select val * 2 from (select id, coales ...
分类:
数据库 时间:
2017-05-28 13:01:21
阅读次数:
598
package kaggle import org.apache.spark.SparkContext import org.apache.spark.SparkConf import org.apache.spark.sql.{SQLContext, SparkSession} import or... ...
分类:
其他好文 时间:
2017-05-26 16:38:01
阅读次数:
274
null like '%%'是有问题的 mysql中应该这样写COALESCE($ZU.mobile,'') like '%%' 或者 ...
分类:
其他好文 时间:
2017-05-24 20:19:06
阅读次数:
156
原材料表: 需求量:生产单里面mrp_production里面的需求数量,这里不能直接和产品相连,因为生产单里面是原材料而产品表里是成品,通过物料清单里的bom表与产品表相连 select t6.产品ID,t6.产品名称,t6.材质,t6.规格,t6.实际库存,(t6.需求总量-t6.已领总量+t6 ...
分类:
其他好文 时间:
2017-05-17 23:44:57
阅读次数:
307
Oracle比较一列的最大值或者最小值,我们会不假思索地用MAX和MIN函数,但是对于比较一行的最大值或最小值呢?是不是日常用的少,很多人都不知道有ORACLE也有内置函数实现这个功能:COALESCE / GREATEST / LEAST. 1. COALESCE 返回该表达式列表的第一个非空va ...
分类:
数据库 时间:
2017-05-13 17:05:32
阅读次数:
267
Hive 是建立在 Hadoop 上的数据仓库基础构架,它提供了一系列的工具,可以用来进行数据提取转化加载(ETL),这是一种可以存储、查询和分析存储在 Hadoop 中的大规模数据的机制。由于 Hive 是针对数据仓库应用设计的,而数据仓库的内容是读多写少的。因此,Hive 中不支持对数据的改写和 ...
分类:
其他好文 时间:
2017-05-12 20:19:16
阅读次数:
141