当之无愧的2018第一神书，虽然出版时间略晚，后发亦可先制。读此书之前可以先读《Streaming 101》和《Streaming 102》预热。《Streaming Systems》沉淀了谷歌过去十多年对流、批计算的思考，前半部分主要阐述了Dataflow模...

/** * scala 将异常信息完成输出到日志中 * @param e * @param data */ def printStackTraceStr(e: Exception, data: String) = { val sw:Strin...

写文件package com.biimport java.io.{File, PrintWriter}/** * Created by xxx on 2017/6/30. */object FileHandler { def fileWriter(fileName: String, conten...

第2行：通过type定义枚举类型的别名 第3行：我们的枚举从1开始，后续枚举值一次加1

package com.biimport java.sql.{Connection, DriverManager, Timestamp}import java.util.Calendar/** * Created by xxx on 2017/6/28. */object MySqlConn {...

val pageLevelId = 3val pageLevelName = "entrance"val funnel = Map(2 -> List(11111), 4 -> List(7), 3 -> List(402, 403), 5 -> List(1572, 1574))val bg = s"$page...

object StringUtils { /** * 判断字符串是否是纯数字组成的串，如果是，就返回对应的数值，否则返回0 * @param str * @return */ def strToInt(str: String): Int = { val regex = ......

flink-release-1.7.2/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcGateway.java

大数据是对海量数据进行存储、计算、统计、分析处理的一系列处理手段，处理的数据量通常是TB级，甚至是PB或EB级的数据，这是传统数据处理手段所无法完成的，其涉及的技术有分布式计算、高并发处理、高可用处理、集群、实时性...

访问ip:8888/about/#step2，点击下载Oozie Editor/Dashboard，可以下载应用程序示例。如下图所示：