sparksql工程小记
最近做一个oracle项目迁移工作，跟着spark架构师学着做，进行一些方法的总结。
1、首先，创建SparkSession对象（老版本为sparkContext）
val session = SparkSession.builder().appName("app1").getOrCreate()
2、数据的更新时间配置表，选用mysql,就是说每次结果数据计算写入mysql后，还会将此次数据的更新时间写入数据配置表。
Spark常用函数（源码阅读六）
源码层面整理下我们常用的操作RDD数据处理与分析的函数，从而能更好的应用于工作中。
连接Hbase,读取hbase的过程，首先代码如下：
def tableInitByTime(sc : SparkContext,tableName : String,columns : Strin...
相比Spark等传统模式，Flink 和 K8S是怎样的结合
Apache Flink 是近年来越来越流行的一款开源大数据计算引擎，它同时支持了批处理和流处理。大数据起源自批处理,Spark最初的定位就是改进Hadoop, 更快速的进行批处理。而Storm擅长的则是进行无状态的流计算(在无状态的流计算领域, 它的延迟是最小的), 进而出现的Flink则是Storm的下一代解决方案。
Scala开启之旅
嘿嘿，公司最近需要测试SPARK性能，赶上了。。
那LUA之后，SCALA也简单看看，，，
其实，我三月时买了本129元的SPARK的书，，全国只那一本哈。
package com.hengheng.
