写入 Hudi 数据集 写操作 DeltaStreamer Datasource Writer 与Hive同步 删除数据 存储管理 写入 Hudi 数据集 这一节我们将介绍使用DeltaStreamer 工具从外部源甚至其他Hudi数据集摄取新更改的方法， 以及通过使用Hudi数据源 的upserts加快大型Spark作业的方法。 对于此...

查询 Hudi 数据集 查询引擎支持列表 读优化表 实时表 Hive 读优化表 实时表 增量拉取 Spark 读优化表 实时表 增量拉取 Presto Impala (3.4 or later) 读优化表 查询 Hudi 数据集 从概念上讲，Hudi物理存储一次数据到DFS上，同时在其上提供三个逻辑视图，如之前 所述。 数...

查询 Hudi 数据集 Hive 读优化表 实时表 增量拉取 Spark 读优化表 实时表 增量拉取 Presto Impala(此功能还未正式发布) 读优化表 查询 Hudi 数据集 从概念上讲，Hudi物理存储一次数据到DFS上，同时在其上提供三个逻辑视图，如之前 所述。 数据集同步到Hive Metastore后，它将提供...

离线数据接口 01. 读取行情接口 02. 读取扩展行情 03. 历史分钟数据 04. 读取板块信息 05. 自定义板块数据 离线数据接口 通过下面的接口，我们可以解析通达信的日K线文件，该文件可以通过读取通达信的软件本地目录导出的数据获取，也可以从通达信的官网上下载， 如果您安装了通达信的终端，可以在安装目录下找到 vipdoc 子目录...

使用 SELECT 语句查询表中的内容。 示例如下： 假设有如下所示数据的表 a 。 obclient > CREATE TABLE a ( id int , name varchar ( 50 ), num int ); Query OK , 0 rows affected ( 0.07 sec ) obcli...

ghttp.Response 对象实现了标准库的http.ResponseWriter 接口。数据输出使用Write* 相关方法实现，并且数据输出采用了Buffer 机制，因此数据的处理效率比较高。任何时候可以通过OutputBuffer 方法输出缓冲区数据到客户端，并清空缓冲区数据。 接口文档：https://godoc.org/github.com/...

数据迁移概述 使用 SQL 脚本迁移 使用 MySQLDump 迁移 使用 DataX 迁移 使用 OUTFILE 语句迁移 使用 OMS 迁移

数据加密 资源操作 规则操作 数据加密 资源操作 ADD RESOURCE ds_0 ( HOST = 127.0 . 0.1 , PORT = 3306 , DB = ds_0 , USER = root , PASSWORD = root ); 规则操作 创建加密规则...

数据分片 资源操作 规则操作 数据分片 资源操作 ADD RESOURCE ds_0 ( HOST = 127.0 . 0.1 , PORT = 3306 , DB = ds_1 , USER = root , PASSWORD = root ); ADD RESOURCE ds_1 ( HOST = 12...

数据加密 配置项说明 数据加密 配置项说明 rules : - ! ENCRYPT tables : < table - name > (+): # 加密表名称 columns : < column - name > (+): # 加密列名称 ...