0x0.执行环境Environment0x1.Source3.KafkaSource直接上代码,从kafka读取数据然后进行处理 example public class Flink04_Source_Kafka { pu

1.Scala_基础package com.ecust.demo /** * @author Jinxin Li * @create 2021-01-11 15:25 */ object SparkCore05_Closure_Sc

集合1.集合基本常用方法object Scala_Collection { def main(args: Array[String]): Unit = { //集合常用的方法 val buffer =

模式匹配1.普通匹配//简单不聊 //todo 常量匹配 def testAge(age:Int)={ age match { case 10 => println("10")

第一章 整体介绍1.1 什么是 Table API 和 Flink SQLFlink本身是批流统一的处理框架，所以Table API和SQL，就是批流统一的上层处理API。 目前功能尚未完善，处于活跃的开发阶段。 Table API是一套内

隐式转换的一些总结1.普通隐式转换/** * @author Jinxin Li * @create 2020-10-28 18:50 * 编译器在编译时,有可能编译不通过 * 尝试在作用域范围内查找可以让程序编译通过的逻辑 *