default：本地表所在库名。 my_table_local：本地表名。 rand()：可选参数，分片键（sharding key），可以是表中一列的原始数据（如did），也可以是函数调用的结果。 如轮训方式：rand()，表示在写入数据时直接将数据插入到分布式表，分布式表引擎会按轮训算法将数据发送到各个分片。

查看更多 →

通过配置“spark.sql.shuffle.partitions”参数可以设置非 DLI 表在OBS桶中插入的文件个数，同时，为了避免数据倾斜，在INSERT语句后可加上“distribute by rand()”，可以增加处理作业的并发量。例如： insert into table table_target

查看更多 →

通过配置“spark.sql.shuffle.partitions”参数可以设置非DLI表在OBS桶中插入的文件个数，同时，为了避免数据倾斜，在INSERT语句后可加上“distribute by rand()”，可以增加处理作业的并发量。例如： insert into table table_target

查看更多 →

返回无比接近 e 的值。 RAND() 返回 [0.0, 1.0) 范围内的伪随机双精度值。 RAND(INT) 返回范围为 [0.0, 1.0) 的伪随机双精度值，初始种子为 INT。 如果两个 RAND 函数具有相同的初始种子，它们将返回相同的数字序列。 RAND_INTEGER(INT)

查看更多 →

--device=/dev/davinci7：挂载NPU设备，示例中挂载了8张卡davinci0~davinci7。 ${work_dir}:${container_work_dir} 代表需要在容器中挂载宿主机的目录。宿主机和容器使用不同的大文件系统，work_dir为宿主机中工作目录，目录下存放着训练所需代码

查看更多 →

into upsert_tab(id, pdate, name) values (1, rand() % 365, 'abc'), (2, rand() % 365, 'bcd'), (1, rand() % 365, 'def'); 查询test_upsert表数据 select *

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入kafka-clients-*.jar，该jar包可在client目录下获取。

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入kafka-clients-*.jar，该jar包可在client目录下获取。

查看更多 →

函数和表达式 概述 由于MySQL中的函数与表达式，在 GaussDB (DWS)中不存在或者存在一定的差异，DSC工具会根据GaussDB(DWS)的支持情况做相应迁移。（兼容ADB for MySQL的语法支持） 类型对照 表1 类型对照表 MySQL/ADB函数类型 描述 MySQL

查看更多 →

方法。 参数说明 表1 参数说明 参数 说明 X-Rtc-Rand 消息请求头中的随机数。 X-Rtc-Timestamp 消息请求头中的时间戳。 X-Rtc-Signature 消息请求头中的签名。 msg 消息请求中body体的内容。 生成录制回调鉴权签名的方法 将如下参数拼接为一个字符串。

查看更多 →

在WiseDBA中纳管和管理数据库实例 在WiseDBA中纳管数据库实例 在WiseDBA中下线及还原数据库实例 在WiseDBA中销毁数据库实例 在WiseDBA中查看数据库实例基础信息 在WiseDBA中变更数据库实例规格 在WiseDBA中为数据库实例添加节点 在WiseDBA中扩容数据库实例磁盘

查看更多 →

运维操作记录选择“紧急问题处理”，并填写紧急原因，单击“提交”。 选择目标节点个数，单击“确定”。 在弹出的提示框中单击“确定”。 父主题： 在WiseDBA中纳管和管理数据库实例

查看更多 →

RDS数据库在备份时间段中是否可用 备份窗口是用户定义的时间段，在该时间段内云数据库RDS实例将进行备份。云数据库RDS服务借助这些定期数据备份，让您能够将云数据库RDS实例还原到保留期内的备份点。 在备份时段期间，业务不受影响，但不能在云数据库RDS服务的管理控制台做重启操作。

查看更多 →

GaussDB数据库在备份时间段中是否可用 备份窗口是用户定义的时间段，在该时间段内云数据库GaussDB实例将进行备份。云数据库GaussDB服务借助这些定期数据备份，让您能够将云数据库GaussDB实例还原到保留期内的备份点。 在备份时段期间，业务不受影响，但不能在云数据库GaussDB服务的管理控制台做重启操作。

查看更多 →

GaussDB(DWS)数据库中的Ruby是什么用户？ 在执行SELECT * FROM pg_user语句查看当前系统的用户时，看到Ruby用户且拥有很多权限。 Ruby用户为官方运维使用账户，GaussDB(DWS)数据库创建后，默认生成Ruby账户，不涉及安全风险，请放心使用。

查看更多 →

如何合并小文件 使用SQL过程中，生成的小文件过多时，会导致作业执行时间过长，且查询对应表时耗时增大，建议对小文件进行合并。 设置配置项。 spark.sql.shuffle.partitions = 分区数量（即此场景下最终生成的文件数量） 执行SQL。 INSERT OVERWRITE

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入 FusionInsight 的kafka-clients-*.jar

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入FusionInsight的kafka-clients-*.jar

查看更多 →

删除RDS for PostgreSQL数据库中的角色失败 问题描述 通过DAS服务界面，执行DROP ROLE test;命令删除RDS for PostgreSQL数据库中的角色test失败。 原因分析 删除角色失败的原因一般为有其他对象依赖于该角色，如果想删除该角色，需要回收角色拥有的其他对象的权限。

查看更多 →

"application/json" } } def get_fake_data(batch_size=8): x = t.rand(batch_size, 1) * 20; y = x * 2 + (1 + t.randn(batch_size, 1)) *

查看更多 →

优先选择其他方法。 说明： 如果只需要在当前数据库连接（即当前Session）中临时更改该参数值，则只需要在SQL语句中执行如下命令： 1 SET enable_nestloop to off; 此参数默认设置为“on”，但实际调优中应根据情况选择是否关闭。一般情况下，在三种join方式（Nested

查看更多 →