配置说明
注意 Tablestore对列值大小有限制。string类型和binary类型的主键列列值限制均为1 KB，属性列列值限制均为2 MB。更多信息，请参见 通用限制。如果数据类型转换后列值超出对应限制，则将该Kafka Record作为脏数据处理。如果使用默认的...
SetQueueAttributes
PollingWaitSeconds Integer 否 0 当Queue消息量为空时，针对该Queue的ReceiveMessage请求最长的等待时间。取值范围：0~30，单位为秒。默认值：0。LoggingEnabled Boolean 否 True 是否开启日志管理功能。取值说明如下：True：启用。False...
GetQueueAttributes
PollingWaitSeconds Integer 0 当Queue消息量为空时，针对该Queue的ReceiveMessage请求最长的等待时间，单位为秒。ActiveMessages Integer 20 在该Queue中处于Active状态的消息总数，为近似值。InactiveMessages Int 0 在该Queue中处于...
pg_stats
null_frac float4 列项中为空的比例。avg_width int4 列的条目的平均字节宽度。n_distinct float4 如果大于零，表示列中可区分值的估计个数。如果小于零，是可区分值个数除以行数的负值（当 ANALYZE 认为可区分值的数量会随着表增长而增加...
pg_stats
null_frac float4 列项中为空的比例。avg_width int4 列的条目的平均字节宽度。n_distinct float4 如果大于零，表示列中可区分值的估计个数。如果小于零，是可区分值个数除以行数的负值（当 ANALYZE 认为可区分值的数量会随着表增长而增加...
GetRange
当返回值不为空时，表示本次GetRange的响应消息中只包含了[inclusive_start_primary_key,next_start_primary_key)间的数据。如果需要继续读取剩下的数据，则需要将next_start_primary_key作为inclusive_start_primary_key，原始请求中的 ...
Kafka数据接入
put 删除模式 当 云消息队列 Kafka 版 消息记录出现空值时，您可以选择是否进行删除行或删除属性列的操作。主键模式 选择 record_key 显示该参数。取值范围如下：none：默认值，不允许进行任何删除。row：允许删除行。column：允许删除属性...
实时同步常见问题
实时同步来源为Oracle、PolarDB、MySQL数据源时，默认不支持处理源端DDL消息，当进行除新建表以外的DDL变更时，实时任务将报错退出。断点续传情况下，可能存在源端未产生DDL消息，但同步仍然报错的情况。说明 为避免数据在某时间段内丢失或...
读取数据
重要 当要读取带有自增主键列的表数据时，请确保已获取到包含自增主键列值在内的完整主键。更多信息，请参见 主键列自增。如果未记录自增主键列的值，您可以使用范围读取数据按照第一个主键列确定范围读取数据。查询方式 说明 适用场景 ...
约束
因为当任何操作数为空时大部分表达式将计算为空值，所以它们不会阻止被约束列中的空值。为了保证一个列不包含空值，可以使用下一节中的非空约束。说明 本数据库不支持引用表数据以外的要检查的新增或更新的行的 CHECK 约束。虽然违反此规则...
实时消费Kafka数据
当您需要将Kafka数据写入 AnalyticDB PostgreSQL版，且不希望使用其他数据集成工具时，可以通过实时数据消费功能直接消费Kafka数据，减少实时处理组件依赖，提升写入吞吐。Apache Kafka是一个容错、低延迟、分布式的发布-订阅消息系统。...
写入数据
当主键为自增列时，只需将自增列的值设置为占位符。更多信息，请参见 主键列自增。数据表可包含1个~4个主键列。主键列是有顺序的，与用户添加的顺序相同，例如PRIMARY KEY（A,B,C）与PRIMARY KEY（A,C,B）是不同的两个主键结构。表格存储会...
函数列表
数据转发到函数计算（FC）writeKafka(destinationId,payload,key)流转数据到消息对列Kafka。key：可选参数，流转到Kafka Topic消息中携带的key。您可以在Kafka消息消费端，通过标签进行消息路由。数据转发到消息队列Kafka writeMns...
pg_settings
pg_settings 视图提供了对服务器上运行时参数的访问。简介 pg_settings 视图提供了对服务器上运行时参数的访问。它本质上是SHOW和SET命令的可替换接口。它还提供了 SHOW 不能提供的关于每一个参数的一些显示，例如，最大值和最小值。列名称...
EMQX数据接入
只有当设置 同步写入 为 false 时生效。异步模式批量间隔（毫秒）否 100 批量写入最长时间间隔。只有当设置 同步写入 为 false 时生效。Tags 否 键：region 值：hangzhou 数据标签，所有数据都以字符串形式处理。数据列名 是 键：clientid ...
Kafka数据源
GSSAPI 配置Kafka数据源时，当 Sasl机制 选择GSSAPI时，需要上传三个认证文件，分别是 JAAS配置文件、Kerberos配置文件 以及 Keytab文件，并在独享资源组进行 DNS/HOST 设置，下面分别介绍三种文件以及独享资源组DNS、HOST的配置方式。...
流式数据湖仓Paimon
部分更新（Partial Update）通过指定部分更新机制（partial-update），您可以通过多条消息对数据进行逐步更新，并最终得到完整的数据。具体来说，具有相同primary key的新数据将会覆盖原来的数据，但值为null的列不会进行覆盖。例如，假设...
CREATE TABLE
当一个类型化的表被创建时，列的数据类型由底层的组合类型决定而没有在 CREATE TABLE 命令中直接指定。但是 CREATE TABLE 命令可以对表增加默认值和约束，并且可以指定存储参数。column_name 列的名称会在新表中被建立.data_type 列的数据...
pg_settings
pg_settings 视图提供了对服务器上运行时参数的访问。简介 pg_settings 本质上是 SHOW 和 SET 命令的可替换接口。它还提供了 SHOW 不能提供的关于每一个参数的一些信息，例如，最大值和最小值。pg_settings 视图包含以下列信息：列名称 ...
条件更新
CompareOperator 对列值进行比较的关系运算符。关于类型的更多信息，请参见 ComparatorType。关系运算符包括EQUAL（=）、NOT_EQUAL!GREATER_THAN（>）、GREATER_EQUAL（>=）、LESS_THAN（<）和LESS_EQUAL（）。LogicOperator 对多个条件...
如何优化高并发IM系统架构
原架构只能有一个队列处理同一个用户的消息，新架构可以多个队列并行处理，当一些用户的消息量突然变大时，也不会立即堵塞其他用户，而是将压力均匀分布给了所有队列。使用主键自增列功能后，应用服务器可以直接写数据到表格存储，不再需要...
Debezium
支持Debezium格式的连接器有 消息队列Kafka 和 对象存储OSS。Flink支持将Debezium JSON和Avro消息解析为INSERT、UPDATE或DELETE消息到Flink SQL系统中。在很多情况下，利用这个特性非常的有用，例如：将增量数据从数据库同步到其他系统 ...
函数列表
规则引擎提供多种函数，您可以在编写SQL时使用这些函数，实现多样化数据处理。数据流转支持的函数 函数名 函数说明 abs(number)返回绝对值。asin(number)返回number值的反正弦。attribute(key)返回key所对应的设备标签。如果设备没有该key...
宽表模型介绍
当一个属性列数据的版本个数超过Max Versions时，表格存储 会异步删除较早版本的数据。更多信息，请参见 最大版本数。核心组件 数据表、行、主键和属性是 表格存储 宽表模型的核心组件。数据表是行的集合，而每个行是主键和属性的集合。...
云数据库Redis
ALL缓存策略目前仅支持hash结构（即hashName参数不为空时）。需要配置相关参数：缓存大小（cacheSize）和缓存更新时间间隔（cacheTTLMs）。cacheSize 缓存大小。Long 否 10000 当选择LRU缓存策略时，需要设置缓存大小。cacheTTLMs 缓存超...
使用自定义Topic通信
订阅：设备订阅该Topic后，当服务端应用发送消息到该Topic时，物联网平台会把消息发送到设备。发布和订阅：具备订阅和发布两个功能，即设备可以将消息通过该Topic发送到物联网平台，同时也可以通过该Topic接收消息。Topic类 Topic格式必须...
INSERT
如果在 return_expression 中指定 table 中的列名，则按如下方式确定在对 return_expression 求值时替换该列的值：如果在 INSERT 命令中为在 return_expression 中指定的列分配值，则在对 return_expression 求值时会使用分配的值。...
表格产品说明书
列标：位于表格编辑窗口上方，用大写英文字母A、B、C……表示，表格的列即被称为A列、B列、C列……。行号：位于表格编辑窗口左侧，用阿拉伯数字1、2、3……表示，表格的行即被称为第1行、第2行、第3行……。⑥ 行号 ⑦ 活动单元格 单元格...
分区索引
对Lindorm宽表的某一列进行HASH分区（即一级HASH分区）时，如果自定义的分区键（也就是Lindorm宽表的某一列）存在热点问题，如一个storeId列下最多可能匹配到10%以上的数据，那么可能导致大量数据写入同一个分区中，影响查询和写入性能。...
条件更新
comparator 对列值进行比较的关系运算符，类型详情请参见 ComparatorType。关系运算符包括EQUAL（=）、NOT_EQUAL!GREATER_THAN（>）、GREATER_EQUAL（>=）、LESS_THAN（<）和LESS_EQUAL（），分别用CT_EQUAL、CT_NOT_EQUAL、CT_GREATER_...
基本语句
因为 quote_literal 被标记为 STRICT，当用一个空参数调用时，它总是会返回空。在上面的例子中，如果 newvalue 或 keyvalue 为空，整个动态查询字符串会变成空，导致从 EXECUTE 得到一个错误。可以通过使用 quote_nullable 函数来避免这种...
错误码参考
对某行进行操作时，包含与主键列同名的属性列。否 400 OTSParameterInvalid Rows count exceeds the upper limit:{limit}.写入的总行数超过了最大限制limit。否 400 OTSParameterInvalid No version condition is specified while querying...
Upsert Kafka
Kafka on EMR可参见文档配置 创建和管理专有网络 和 安全组概述，云消息队列 Kafka 版 需要 配置白名单。使用限制 仅Flink计算引擎VVR 2.0.0及以上版本支持消息队列Kafka连接器。仅支持读取和写入Apache Kafka 0.10及以上版本的数据。仅...
文字产品说明书
选定文本和对象 当要对文本或对象进行编辑时，需要先选定要操作的文本块或对象。在文字文档中，用户可以使用鼠标、键盘或键盘配合鼠标选定文本，而对象只能通过鼠标或键盘配合鼠标来选定。选定文本 鼠标操作 根据要选择的范围的不同，执行...
条件更新
只有当数据满足列判断条件时，才能对数据表中的数据进行更新；当数据不满足列判断条件时，数据更新失败。场景 适用于对高并发应用进行更新的场景，用于保证数据正确性和一致性。在高并发场景下，原有列值（old_value）可能会被其他客户端...
PolarDB PostgreSQL 14版相对于PolarDB PostgreSQL 11...
如果没有提供参数列表并且存在多个匹配的对象，则使用 DROP IF EXISTS FUNCTION/PROCEDURE/AGGREGATE/ROUTINE 时会产生错误，还改进了这种情况下的错误消息。插件和工具 不允许在psql的 \pset format 命令中使用非唯一的缩写。在PG 11版本...
ANALYZE
输出 当指定了 VERBOSE 时，ANALYZE 会发出进度消息来指示当前正在处理哪个表。还会打印有关那些表的多种统计信息。说明 要分析表，通常必须是该表的所有者或超级用户。不过，数据库所有者可以分析数据库中的所有表，共享目录除外。（对...
其他函数
示例2：将STRING数据类型值转换成BOOLEAN数据类型，当STRING为空字符串时返回 false，否则返回 true。命令示例如下。STRING为空字符串。select cast(""as boolean);返回+-+|_c0|+-+|false|+-+STRING为非空字符串。select cast("false"as ...
使用云数据库ClickHouse时需要避免的操作
当您每次使用可空列时，都必须处理这个额外的列。这会导致增加额外的存储空间，并且总是对性能产生负面影响。Nullable Columns可以通过为列设置一个默认值来避免这个额外的列，但是不推荐使用以下操作：CREATE TABLE default.sample(`x` ...
同步 OceanBase 数据库的数据至 DataHub
当更新的行包括 LOB 列时：如果 LOB 列为更新列，请勿依赖 LOB 列在 UPDATE 或 DELETE 操作前的值。目前使用 LOB 列进行存储的数据类型包括 JSON、GIS、XML、UDT（用户定义类型），以及 LONGTEXT、MEDIUMTEXT 等各类 TEXT。如果 LOB 列为非...
- 产品推荐
- 这些文档可能帮助您