FlinkCEP - Flink的复杂事件处理 开始 模式API 单个模式 量词 条件 组合模式 循环模式中的连续性 模式组 匹配后跳过策略 检测模式 从模式中选取 处理超时的部分匹配 便捷的API CEP库中的时间 按照事件时间处理迟到事件 时间上下文 例子 从旧版本迁移（1.5之前） Migrating from Fli...

异步命令处理 异步命令处理 PQexec函数对普通的同步应用里提交命令已经足够使用。但是它却有几个缺陷，而这些缺陷可能对某些用户很重要： PQexec等待命令结束，而应用可能还有其它的工作要做（比如维护用户界面等），此时PQexec可不想阻塞在这里等待响应。 因为客户端应用在等待结果的时候是处于挂起状态的，所以应用很难判断它是否该尝试结束正在...

概述 数据操纵语言 （Data Manipulation Language, DML）是SQL语言中，负责对数据库对象运行数据访问工作的指令集，以INSERT、UPDATE、DELETE三种指令为核心，分别代表插入、更新与删除，是开发以数据为中心的应用程序必定会使用到的指令，除此之外，OceanBase还支持REPLACE、INSERT INTO…ON...

异常现象 定位合并异常 Server 异常原因定位 解决方案 异常现象 一般 OceanBase 集群合并出现异常时，在 OCP 中会触发 OCP 合并超时或合并错误告警，告警信息如下图所示： 同时 OceanBase 日志监控中也会出现类似合并相关的错误，告警信息如下图所示： 收到合并异常告警后，管理员可登录对应告警对象的 O...

自定义回调处理是最常见的接口开发实现，我们往往只需要对接口中的部分实现进行替换修改，以在原有的实现逻辑中注入自定义的逻辑实现。我们来看一个自定义回调处理的示例，我们需要将所有执行的SQL 语句记录到monitor 表中，以方便于进行SQL 审计。 为简化示例编写，我们这里实现了一个自定义的MySQL 驱动，该驱动继承于gdb 模块中已经实现的Driver...

静态文件处理 静态文件处理 前面我们介绍了如何输出静态页面，但是我们的网页往往包含了很多的静态文件，包括图片、JS、CSS 等，刚才创建的应用里面就创建了如下目录： ├── static │ ├── css │ ├── img │ └── js beego 默认注册了...

基本介绍 转换示例 示例1，设置loc=Local 示例2，不设置loc 参数 改进方案 基本介绍 这个问题由于大家问得比较多，因此单独开了一个章节详细介绍一下ORM 中的时区处理是怎么一回事。我们这里以MySQL 数据库为基础来介绍时区转换的事情，本地时区我们设定为+8 时区，数据库时区也是+8 时区。 MySQL 数据库驱动用得最多的...

通过状态快照实现容错处理 State Backends 状态快照 定义 状态快照如何工作？ 确保精确一次（exactly once） 端到端精确一次 实践练习 延伸阅读 通过状态快照实现容错处理 State Backends 由 Flink 管理的 keyed state 是一种分片的键/值存储，每个 keyed state 的工...

数据预处理 一、飞桨框架内置数据集 二、自定义数据集 数据预处理 训练过程中有时会遇到过拟合的问题，其中一个解决方法就是对训练数据做增强，对数据进行处理得到不同的图像，从而泛化数据集。数据增强API是定义在领域目录的transofrms下，这里介绍两种使用方式，一种是基于框架内置数据集，一种是基于自定义的数据集。 一、飞桨框架内置数据集 针...

缺失值填充 缺失值填充预测(batch) 缺失值填充训练(batch) 缺失值填充预测(stream) 采样(batch) 采样(stream) 按个数采样(batch) VectorNormalize(batch) VectorNormalize(stream) VectorNormalize 标准化 标准化训练(batch) 标准...