写入数据 功能简介 使用OpenTSDB的接口(/api/put)写入数据。 函数genWeatherData()模拟生成的气象数据，函数putData()发送气象数据到OpenTSDB服务端。 样例代码 以下代码片段在com.huawei.bigdata.opentsdb.ex

查看更多 →

数据写入 写入更新数据时报错 Parquet/Avro schema 写入更新数据时报错UnsupportedOperationException 写入更新数据时报错SchemaCompatabilityException Hudi在upsert时占用了临时文件夹中大量空间 Hudi写入小精度Decimal数据失败

查看更多 →

数据写入 写入更新数据时报错 Parquet/Avro schema 写入更新数据时报错UnsupportedOperationException 写入更新数据时报错SchemaCompatabilityException Hudi在upsert时占用了临时文件夹中大量空间 Hudi写入小精度Decimal数据失败

查看更多 →

写入数据 写入数据接口和HBase原生API一致。 样例代码 public void testPut() { LOG .info("Entering testPut."); try(Table table = conn.getTable(tableName)) { List<Put>

查看更多 →

Kafka数据库端口”，单击“测试”测试 DLI 到Kafka网络是否可达。 创建DLI连接RDS的增强型跨源连接 在RDS管理控制台，选择“实例管理”，单击对应的RDS实例名称，进入到RDS的基本信息页面。 在“基本信息”的“连接信息”中获取该实例的“内网地址”、“数据库端口”、“

查看更多 →

afka内网地址:Kafka数据库端口”，单击“测试”测试DLI到Kafka网络是否可达。 创建DLI连接DWS的增强型跨源连接 在DWS管理控制台，选择“集群管理”，单击已创建的DWS集群名称，进入到DWS的基本信息页面。 在“基本信息”的“数据库属性”中获取该实例的“内网IP

查看更多 →

Spark如何将数据写入到DLI表中 使用Spark将数据写入到DLI表中，主要设置如下参数： fs.obs.access.key fs.obs.secret.key fs.obs.impl fs.obs.endpoint 示例如下： import logging from operator

查看更多 →

连接信息，地址栏输入“Kafka内网地址:Kafka数据库端口”，单击“测试”测试DLI到Kafka网络是否可达。 创建DLI连接 CSS 的增强型跨源连接 在 CS S管理控制台，选择“集群管理”，单击已创建的CSS集群名称，进入到CSS的基本信息页面。 在“基本信息”中获取CSS的“

查看更多 →

by建表属性，去重键以order by字段为准。 数据去重的key需要提前在应用中进行sharding计算，保证相同的key会sharding到同一个shard，才能保证后续相同的key字段数据sharding到同一个shard进行数据的精确去重。 父主题： ClickHouse常用SQL语法

查看更多 →

如何将本地数据库备份恢复到云数据库RDS 可以使用DRS迁移功能，将本地数据库备份恢复到云上数据库。具体请参见入云迁移。 更多备份恢复方案，请参见恢复方案概览。 父主题： 备份与恢复

查看更多 →

如何将本地数据库备份恢复到云数据库 GaussDB 可以使用数据复制服务（Data Replication Service，简称DRS）的迁移功能，将本地数据库备份恢复到云上数据库。具体请参见入云迁移。 更多备份恢复方案，请参见数据恢复。 父主题： 备份与恢复

查看更多 →

使用Flink Jar写入数据到OBS开发指南 概述 DLI提供了使用自定义Jar运行Flink作业并将数据写入到OBS的能力。本章节JAVA样例代码演示将kafka数据处理后写入到OBS，具体参数配置请根据实际环境修改。 环境准备 已安装和配置IntelliJ IDEA等开发工具以及安装JDK和Maven。

查看更多 →

引用数据库或者导入数据到指定数据库 使用import命令引用数据库实例到当前所在项目或者导入数据到指定数据库。 命令结构 health import database instance <instance-id> [flags] 或者 health import db instance

查看更多 →

恢复到云耀数据库 按备份文件恢复全量数据 恢复全量数据到指定时间点 父主题： 备份恢复

查看更多 →

如何关闭数据库SSL？ 操作场景 通过“免安装Agent”方式审计数据库时，不需要执行关闭数据库SSL操作。请跳过本章节。 通过“安装Agent”方式审计数据库时，关闭数据库的SSL是必要操作。如果您开启了数据库SSL，将无法获取审计数据。 如果想一直开启数据库的SSL来保证数据

查看更多 →

ERT，当初始化数据集时建议使用BULK_INSERT。 批量写入Hudi表 引入Hudi包生成测试数据，参考快速入门章节的2到4。 写入Hudi表，写入命令中加入参数：option("hoodie.datasource.write.operation", "bulk_inser

查看更多 →

hudi.examples.TransformerExample // 指定如何处理数据源拉取来的数据，可根据自身业务需求做定制 --enable-hive-sync // 开启hive同步，同步hudi表到hive --continuous // 指定流处理模式为连续模式 父主题：

查看更多 →

ERT，当初始化数据集时建议使用BULK_INSERT。 批量写入Hudi表 引入Hudi包生成测试数据，参考从零开始使用Hudi章节的2到4。 写入Hudi表，写入命令中加入参数：option("hoodie.datasource.write.operation", "bulk

查看更多 →

从MySQL CDC源表读取数据写入到DWS 本指导仅适用于Flink 1.12版本。 场景描述 CDC是变更数据捕获（Change Data Capture）技术的缩写，它可以将源数据库的增量变动记录，同步到一个或多个数据目的中。CDC在数据同步过程中，还可以对数据进行一定的处理，例如分组（GROUP

查看更多 →

为什么HBase无法写入数据？ 问题现象 HBase无法写入数据，导致应用侧业务数据无法及时更新。 原因分析 Zookeeper连接数过多。 处理方法 建议业务代码连接同一个CloudTable HBase集群时，多线程创建并复用同一个Connection，不必每个线程都创建各自

查看更多 →

Flume数据写入组件失败 问题现象 Flume进程启动后，Flume数据无法写入到对应组件（本示例以服务端写入到HDFS为例）。 原因分析 HDFS未启动或故障。 查看Flume运行日志： 2019-02-26 11:16:33,564 | ERROR | [SinkRunne

查看更多 →