全局二级索引

每个GSI对应一张分布索引,和其他分布式表一样,按照指定的分区规则水平拆分为多张物理。PolarDB-X 使用分布事务维护主和索引之间数据强一致。全局二级索引还支持以下特性:支持选择覆盖列,减少回操作开销。在线结构变更...

ClickHouse

Boolean 否 false 参数取值如下:false(默认值):如果是写ClickHouse分布式表,并且在参数url中只指定了一个节点,则不会尝试推测分布式表对应的本地信息,而是依然会直接写入分布式表,再由分布式表写入对应的本地。true:Flink将...

社区兼容版集群垂直变配和水平扩缩容

检测失败原因有以下两种:缺失唯一的分布式表:表示本地没有创建分布式表,需要再创建一个对应的分布式表。对应的分布式表不唯一:表示本地有不止一个分布式表,请删除多余的分布式表,仅保留一个即可。在 变配 或 降配 页面,根据您的...

云数据库ClickHouse集群间的数据迁移

本地和分布式表检测 如果存在本地没有创建分布式表或者分布式表不唯一,则校验失败。请删除多余的分布式表。迁移任务完成后,在 实例迁移 页面查看迁移任务。说明 当迁移任务的 迁移状态 为 已完成 时,说明源集群的数据已成功迁移至...

总体流程

创建:以创建与On Time数据集类型对应的为例,介绍如何使用DMS在已创建的数据库中创建本地和分布式表。导入数据:以导入On Time数据集至已创建的分布式表为例,介绍如何使用客户端clickhouse-client工具导入数据到 云数据库...

CREATE TABLE

创建分布式表 分布式表是本地的集合,它将多个本地抽象为一张统一的,对外提供写入、查询功能。当数据写入分布式表时,会被自动分发到集合中的各个本地中。当查询分布式表时,集合中的各个本地都会被分别查询,并且把最终结果...

基本概念

分布式表(Distributed Table)本地的集合,它将多个本地抽象为一张统一的,对外提供写入、查询功能。当写入分布式表时,数据会被自动分发到集合中的各个本地中;当查询分布式表时,集合中的各个本地都会被分别查询,并且把最终...

升级内核大版本

本地和分布式表检测 如果存在本地没有创建分布式表或者分布式表不唯一,则校验失败。请删除多余的分布式表。迁移任务完成后,在 实例迁移 页面查看迁移任务。说明 当迁移任务的 迁移状态 为 已完成 时,说明源集群的数据已成功迁移至...

从MySQL导入数据

说明 如果您导入的是本地,请将查询语句中的分布式表名 clickhouse_test_table_distributed 更换为本地名 clickhouse_test_table,再进行查询。查询结果如下。数据类型映射 RDS MySQL或PolarDB MySQL类型 ClickHouse类型 Unsigned ...

从Kafka同步数据

说明 如果您同步的目的是本地,请将查询语句中的分布式表名更换为本地名,再进行查询。查询结果如下。id─┬─name─┐│1│a│2│b│└─┴─┘说明 当您执行查询语句并成功返回结果时,说明数据已从Kafka同步至 云数据库ClickHouse...

创建

本文介绍如何使用DMS(Data Management Service)在云数据库ClickHouse中创建。前提条件 已完成快速入门的如下步骤。新建集群 创建账号 设置白名单 连接集群 创建数据库 操作步骤 在的 SQL Console 页面中,输入 CREATE TABLE 语句创建...

2022-03-04版本

通过对分布式表的本地进行直接写入的方式,可以显著提高写ClickHouse分布式表的吞吐量。ClickHouse结果 优化作业诊断规则和界面 新增20多种诊断规则,全面分析作业的运行状态。根据作业的实际情况,给出高、中、低三种风险等级提示。...

常见问题

如何处理建后查询不存在?为什么Kafka外表建后数据不增加?为什么客户端看到的时间结果和时区显示的不一样?为什么数据写入后不可见?为什么optimize任务很慢?为什么optimize后数据仍未主键合并?为什么optimize后数据TTL仍未生效?...

从OSS导入数据

您可以通过引擎或函数将数据从OSS中导入至 云数据库ClickHouse,实现日志查询分析和加工等操作。本文介绍如何将OSS数据导入至 云数据库ClickHouse。前提条件 已开通OSS服务。如何开通,请参见 开通OSS服务。已创建存储空间(Bucket),...

Multi-Master关键技术介绍

本文对Multi-Master架构的关键技术点进行介绍,包括分布事务处理、全局死锁处理、DDL支持、分布式表锁支持、集群容错和高可用能力。分布事务管理 AnalyticDB PostgreSQL版 分布事务 AnalyticDB PostgreSQL版 通过二阶段提交协议(2PC...

术语

AUTO AUTO模式数据库中,建时未使用PARTITION语法的称为AUTO,AUTO是分布的。分区 AUTO模式数据库中,创建时使用了 PARTITION 语法的称为分区组(Table Group)AUTO模式数据库中,为了尽可能避免跨机器查询,提高...

MySQL分库分表同步至Hologres(方案1.0)

将分表数据写入目标单:将源满足 t_order.*正则表达数据写入到Hologres名为 t_order 的中,所有满足 t_user.*正则表达数据写入到Hologres名为 t_user 的中。为加上统一前缀:在目标名前统一加上 cdo_前缀。schema:...

MySQL分库分表同步至Hologres(方案2.0)

将分表数据写入目标单:将源满足 t_order.*正则表达数据写入到Hologres名为 t_order 的中,所有满足 t_user.*正则表达数据写入到Hologres名为 t_user 的中。为加上统一前缀:在目标名前统一加上 cdo_前缀。schema:...

安装Proxima CE包

输入表格要求 名 输入名不能包含 tmp_字符串,否则会导致任务运行失败。输入名和分区名的字符长度不能超过64,否则会导致任务运行失败。字段 固定字段 字段说明 字段数据类型 pk 查询时的pk值字段。默认为STRING类型。对于...

Hologres整库周期性增全量同步至MaxCompute

结构迁移中包含目标的创建方式(已有/自动建),如果是自动建,则会为您展示建的DDL。全量同步中包含离线同步的信息、同步的进度、以及写入的条数。增量同步中包含周期任务对应的最新周期实例的相关指标信息。任务重跑 直接重...

AnalyticDB for MySQL3.0整库周期性增全量同步至...

结构迁移中包含目标的创建方式(已有/自动建),如果是自动建,则会为您展示建的DDL。全量同步中包含离线同步的信息、同步的进度、以及写入的条数。增量同步中包含周期任务对应的最新周期实例的相关指标信息。任务重跑 直接重...

配置示例:MaxCompute

配置分区表达 数据质量通过分区表达来确定需要配置的规则:如果您的检查对象为非分区,可以配置分区表达为 NOTAPARTITIONTABLE。如果您的检查对象为分区,可以配置为业务日期的表达(例如$[yyyymmdd-1])。说明 数据质量规则中...

流控规则参数说明

目前已支持下面的表达:表达 说明 备注 args0 当前参数的值 无 args0.name 参数的name属性 会翻译成Java语句:arg.getName()。args0.isEnabled()参数的enabled属性,是一个bool类型。Java规范里,bool类型的getter格式是 isXXX()。args...

MySQL整库周期性增全量同步至Hive

此操作会影响通过数据集成新建结构,已有的表格不受影响。新建存储方式:可以选择 内、外表,决定新建目标格式是内还是外表。新建格式:可以选择 parquet、orc、txt,决定新建目标的存储格式。写入模式:决定任务在...

Spark SQL

同样的,建语句必须显指定的存储 LOCATION 信息,类似如下SQL语句。CREATE TABLE table1(col1 INT)LOCATION 'oss:/test/db1/table1/';需要注意以下几个事项:当用户在Spark中DROP一个或者的某个 PARTITION 时,并不会删除OSS上的...

IO加速

适用场景 下列是一些IO加速功能适用的业务场景:排序、分组聚合、联合等产生临时结果的复杂操作 使用CTE通用表达的递归查询 无法使用适当索引的复杂查询 对大或多个的分析型查询 其他使用临时的工作负载 支持范围 满足以下条件的...

概述

SELECT 命令的一般语法是[WITH with_queries]SELECT select_list FROM table_expression[sort_specification]下面几个小节描述选择列表、表达和排序声明的细节。WITH 查询等高级特性将在最后讨论。一个简单类型的查询的形式:SELECT*...

离线同步能力说明

示例:创建一个离线同步任务,每天从源MySQL订单中同步前一天新产生的订单数据到MaxCompute目标的当天分区,原订单的创建时间字段为 gmd_created,目标odps的分区字段为 ds,可以将任务配置如下:同步任务配置:调度参数配置:订单...

全增量实时同步至Hologres

如上图所示,使用 源端名 将源端名作为目标名称,并且将源端名中符合 t_order.*正则表达数据写入到Hologres名为 t_order 中。应用目标schema名与名映射规则。选中待同步的所有,单击 批量修改>目标Schema名映射自定义 ...

逻辑表达式

本文介绍在新建逻辑时,输入逻辑表达的规则。简单规则 规则 举例说明 自然序 test_[0-7]:创建8张。自然对齐序 test_[00-07]:创建8张名两位对齐。test_[000-007]:创建8张名三位对齐。test_[0000-0007]:创建8张,...

使用Tapdata Cloud导入MySQL数据

按正则表达匹配:使用正则表达匹配满足表达作为要复制的。使用此方式时,当源库中新增的满足表达时,该也会被自动同步到目标库。批量读取条数 全量同步时,每批次读取的记录条数,默认为100。单击Tablestore数据库,预览...

逻辑结构设计

数据管理DMS提供的结构设计功能,可以实现对目标库进行符合研发规范的结构设计。您可按需自定义不同业务线的研发流程,保障多套环境(例如开发环境、测试环境、生产环境)之间结构的一致性。本文介绍逻辑结构设计的方法。背景信息 分...

分区

分区可以使用继承来实现,这能够带来一些声明分区不支持的特性,例如:对声明分区来说,分区必须具有和分区正好相同的列集合,而在继承中,子可以有父中没有出现过的额外列。继承允许多继承。声明分区仅支持范围、列表...

将Oracle数据同步到表格存储

按正则表达匹配:使用正则表达匹配满足表达作为要复制的。使用此方式时,当源库中新增的满足表达时,该也会被自动同步到目标库。批量读取条数 全量同步时,每批次读取的记录条数,默认值为100。一般保持默认值即可。日志...

配置规则:按(单

数据质量支持按照数据配置质量监控规则,用来监控数据是否符合要求,自动拦截问题任务,阻断脏数据向下游蔓延,保障产出的数据符合预期。规则配置完成后,您可先试跑该规则,确保质量规则的配置符合预期。同时,还可对质量规则执行...

OceanBase(公测中)

类别 详情 支持类型 源、维和结果 运行模式 流模式和批模式 数据格式 暂不适用 特有监控指标 暂无 API种类 SQL 是否支持更新或删除结果数据 是 前提条件 连接的数据库和都已被创建。具体操作可参考以下文档:MySQL模式 CREATE ...

CREATE TABLE AS(CTAS)语句

通过CTAS语句,在实时同步数据的同时,还能实时将上游结构(Schema)的变更同步到下游,提高您在目标存储中创建和维护源结构变更的效率。本文为您介绍CREATE TABLE AS(CTAS)的使用方法,并提供了多种使用场景下的示例。前提条件 ...

批读写

与不指定路径的内部不同,当您使用DROP时,不会删除外部的文件 如果运行CREATE TABLE的位置已经包含使用Delta Lake存储的数据,Delta Lake将执行以下操作:如果只指定名和位置,例如:SQL%sql CREATE TABLE events USING DELTA ...

CREATE TABLE

CREATE TABLE 用于在当前数据库中创建一个新的、初始为空的。简介 CREATE TABLE 将在当前数据库中创建一个新的、初始为空的。该将由发出该命令的用户所拥有。如果给定了一个模式名(例如 CREATE TABLE myschema.mytable.),那么该...

表达式

本文介绍了表达的相关内容。简介 表达计算一个。该表达包含一个 FROM 子句,该子句后面可以根据需要选用 WHERE、GROUP BY 和 HAVING 子句。最简单的表达只是引用磁盘上的一个,一个所谓的基本,但是我们可以用更复杂...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云数据库Cassandra版 弹性公网IP 短信服务 人工智能平台 PAI 金融分布式架构 对象存储
新人特惠 爆款特惠 最新活动 免费试用