第 3 章 Dstream 创建 Spark Streaming 原生支持一些不同的数据源。一些“核心”数据源已经被打包到 Spark Streaming 的 Maven 工件中，而其他的一些则可以通过 spark-streaming-kafka 等附加工件获取。 每个接收器都以 Spark 执行器 ...
分类：
其他好文 时间：
2019-07-09 19:30:00
阅读次数：
98
IEC 61499标准通常用于开发分布式控制系统。IEC 61499定义了功能模块（FB, function block）的模型。有三种FB，分别是Basic FB (BFB)，Service Interface FB (SIFB) （有的文献也称作Service FB (SFB)）和Composi ...
分类：
其他好文 时间：
2019-07-07 14:48:36
阅读次数：
193
? 前面我们系统了解了一个查询语句的执行流程，并介绍了执行过程中涉及的处理模块。相信你还记得，一条查询语句的执行过程一般是经过连接器、分析器、优化器、执行器等功能模块，最后到达存储引擎。 那么，一条更新语句的执行流程又是怎样的呢？之前你可能经常听 DBA 同事说，MySQL 可以恢复到半个月内任意一 ...
分类：
数据库 时间：
2019-06-21 21:08:07
阅读次数：
179
部署搭建好SIA-TASK任务调度平台之后，编写TASK后配置JOB进行调度，进而实现整个调度流程。本文新建JOB示例，介绍JOB怎样关联配置两个级联TASK，以及如何通过SIA-TASK实现任务调度，最终实现对两个TASK执行器的调用。 ...
分类：
其他好文 时间：
2019-06-18 14:33:30
阅读次数：
115
用户自定义函数（UDF）是大多数SQL环境的一个关键特性，其主要用于扩展系统的内置功能。UDF允许开发人员通过抽象其低级语言实现在更高级语言（如SQL）中应用的新函数。ApacheSpark也不例外，其为UDF与SparkSQL工作流集成提供了各种选项。在本篇博文中，我们将回顾Python、Java和Scala上的ApacheSparkUDF和UDAF（用户自定义的聚合函数）实现的简单示例。我们还
分类：
Web程序 时间：
2019-06-14 12:32:46
阅读次数：
131
【Hibernate】 113. 为什么要使用 hibernate？ hibernate 是对 jdbc 的封装，大大简化了数据访问层的繁琐的重复性代码。 hibernate 是一个优秀的 ORM 实现，很多程度上简化了 DAO 层的编码功能。 可以很方便的进行数据库的移植工作。 提供了缓存机制，是 ...
分类：
编程语言 时间：
2019-05-04 00:30:56
阅读次数：
837
一条SQL查询语句是如何执行的 下面是MySql的基本架构示意图，从图中可以清楚地看到SQL语句在MySQL的各个功能模块中的执行过程。 大体来讲，MySQL可以分为Server层和存储引擎层两部分。 Server层 Server层包括连接器、查询缓存、分析器、优化器、执行器等，涵盖了MySql的大 ...
分类：
数据库 时间：
2019-05-03 18:33:48
阅读次数：
192
一.springboot开线程执行异步任务 1.Spring通过任务执行器TaskExecutor，来实现多线程和并发编程，使用ThreadPoolTaskExecutor可实现一个基于线程池的TaskExecutor; 2.异步需要在配置类上面加@EnableAsync 来开启对异步任务的支持在需 ...
分类：
编程语言 时间：
2019-04-29 19:10:25
阅读次数：
174
1.定义 LIN（Local Interconnect Network）总线是基于UART/SCI（通用异步收发器/串行接口）的低成本串行通讯协议。其目标定位于车身网络模块节点间的低端通信，主要用于智能传感器和执行器的串行通信。 2.背景 3.拓扑结构 4.工作机理 总线任务负责： 1. 调度总线上 ...
分类：
其他好文 时间：
2019-04-25 11:43:51
阅读次数：
1525
