StreamTableEnvironment 该类包含sql解析、验证、优化、执行等各环节需要的元数据管理器 ,模块管理器(模块包含函数集、类型集、规则集) ，用户自定义函数管理器 ,线程池、sql解析器 。 DataType 定义了逻辑类型，并且对其底层实际物理类型进行暗示。 LogicalTyp ...
分类：
数据库 时间：
2019-11-11 18:23:01
阅读次数：
112
fastjson无法转换 case class 为json ...
分类：
Web程序 时间：
2019-11-11 00:29:26
阅读次数：
249
[TOC]一、scala概述1.1简介?scala是一种多范式的编程语言，其设计的初衷是要集成面向对象编程和函数式编程的各种特性。Scala运行于Java平台（Java虚拟机），并兼容现有的Java程序。它也能运行于CLDC配置的JavaME中。目前还有另一.NET平台的实现，不过该版本更新有些滞后。Scala的编译模型（独立编译，动态类加载）与Java和C#一样，所以Scala代码可以调用Jav
分类：
其他好文 时间：
2019-11-10 21:10:46
阅读次数：
121
一：文件和正则表达式 读取行 import scala.io.Source val lines = Source.fromFile("D://report_data2.txt","UTF-8").getLines() for( i <- lines) println(i)//遍历每一行的数据 val ...
分类：
其他好文 时间：
2019-11-10 15:22:33
阅读次数：
83
我们都知道Kafka非常快，比绝大多数的市场上其他消息中间件都要快。这里来研究下那么为什么Kafka那么快（当然不会是因为它用了Scala）。 Kafka的消息是保存或缓存在磁盘上的，一般认为在磁盘上读写数据是会降低性能的，因为寻址会比较消耗时间。 但是实际上，Kafka其中一个特性却是高吞吐率，即 ...
分类：
其他好文 时间：
2019-11-10 10:28:53
阅读次数：
93
https://github.com/scalanlp/breeze/wiki/Linear-Algebra-Cheat-Sheethttps://docs.scipy.org/doc/numpy-1.13.0/reference/routines.linalg.htmlhttp://blog.cs ...
分类：
其他好文 时间：
2019-11-10 10:07:27
阅读次数：
88
一：数组相关操作 定长数组 val array = Array[String]("a","b","c") //直接初始化数组的内容 println(array.mkString("|")) val array = new Array[String](2) //new一个长度为2的数据在通过更新的方法 ...
分类：
编程语言 时间：
2019-11-09 20:06:46
阅读次数：
91
scala的wordcount实例 package com.wondersgroup.myscala import scala.actors.{Actor, Future} import scala.collection.mutable.ListBuffer import scala.io.Sour ...
分类：
其他好文 时间：
2019-11-09 19:56:33
阅读次数：
99
安装scala 上传安装包 解压 配置scala相关的环境变量 验证scala安装是否成功 把scala分发给node2 node3 node4 分别给node2 node3 node4配置scala的环境变量，并使其生效 spark安装包下载地址：https://archive.apache.or ...
分类：
其他好文 时间：
2019-11-09 19:51:52
阅读次数：
84
1、scala的主构造器和辅助构造器，scale可以有多个辅助的构造器，但是只能有一个主构造器 package com.itstar.scala.test/** * 定义学生类并且使用了主构造器 * Scala里面只有一个主构造器，可以有多个辅助构造器 * @param stuName * @par ...
分类：
其他好文 时间：
2019-11-09 00:39:37
阅读次数：
95
