检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
o，实现了生产数据的REST API以及消费数据的REST API。参考Kafka对接SpringBoot样例代码。 父主题： Kafka开发指南（安全模式）
运行统计样例程序 确保样例工程依赖的所有jar包已正常获取。 在IntelliJ IDEA开发环境中，打开样例工程中“LocalRunner.java”工程，右键工程，选择“Run LocalRunner.main()”运行应用工程。 运行多组件样例程序 将hive-site.xml、hbase-site
Spark Streaming对接Kafka0-10样例程序开发思路 Spark Streaming对接Kafka0-10样例程序（Java） Spark Streaming对接Kafka0-10样例程序（Scala） 父主题： 开发Spark应用
使用场景 API网关主要涉及以下几个开发场景： API调用认证开发：API的认证方式为APP认证或IAM认证，则需要在业务系统侧进行调用认证的开发，为API请求添加认证信息。 使用APP认证（签名认证）调用API：API调用者通过API网关提供Key、Secret和SDK，对API请求进行签名认证。
execute(); } catch (Exception e) { logger.error("Execute sql {} failed.", sql, e); throw new Exception(e); } } 父主题： Doris JDBC接口调用样例程序
的记录创建或者更新时，给用户“zhangsan@qq.com”发送通知邮件。 创建上述触发器前，请已成功创建邮件模板并配置Email告警。通过该Email告警，系统可以给用户“test123@qq.com”发送电子邮件。如何新建邮件模板，请参见邮件模板。 创建触发器 参考登录As
, W_GMT_OFFSET DECIMAL(5,2), CONSTRAINT W_CONSTR_KEY3 UNIQUE(W_WAREHOUSE_SK) )DISTRIBUTE BY HASH(W_WAREHOUSE_SK);
Spark从HBase读取数据再写入HBase样例程序开发思路 Spark从HBase读取数据再写入HBase样例程序（Java） Spark从HBase读取数据再写入HBase样例程序（Scala） Spark从HBase读取数据再写入HBase样例程序（Python） 父主题： 开发Spark应用
user_9，user_00 到 user_99 的表。 说明： 如果配置了时间宏变量，通过DataArts Studio数据开发调度CDM迁移作业时，系统会将时间宏变量替换为“数据开发作业计划启动时间-偏移量”，而不是“CDM作业实际启动时间-偏移量”。 TABLE_EXAMPLE 高级属性 Where子句
代码解析 项目结构如下 表1 类相关说明 类名称 描述 Device 设备类，包含设备的id，产品id，slaveId及能力定义。 Main 主启动类。 ModbusCfg modbus配置。 ModbusDriver 业务主体类，该类含边侧设备添加，设备同步，数据收集及上报等演示。
卸载应用 使用说明 系统支持开发者用户，在开发环境删除自己创建或安装的源码包应用。 卸载应用 参考登录管理中心中操作，登录AstroZero管理中心。 在左侧导航栏中，选择“应用管理 > 应用导航”。 在应用程序列表中，单击待卸载源码包应用后的，删除应用。 父主题： 应用管理
error("error") # 打印一条fatal级别的日志 hilens.fatal("fatal") if __name__ == '__main__': hilens.init("hello") run() hilens.terminate() 父主题： 日志模块
集成 简介 集成PC端应用到ISDP+系统 集成大屏应用到ISDP+系统 集成移动端应用到ISDP+ Mobile系统 接入端侧设备到ISDP+系统 父主题： 用户指南
注意事项 传输安全 为了传输安全，REST API必须通过HTTPS传输，不支持HTTP传输。 HTTP编码 请求及返回结果都使用UTF-8字符集进行编码。
完成服务环境的准备和开发环境的准备。服务环境准备包括准备华为账号和访问密钥，是使用SDK与OBS云服务交互的必要条件。开发环境准备是指为了您能顺利完成SDK的安装、完成基于SDK的代码开发与运行，需要提前在本地完成的开发环境搭建，比如下载安装依赖软件、安装开发工具等。 准备华为账号
class FemaleInfo(name: String, gender: String, stayTime: Int) def main(args: Array[String]) { // 通过spark接口获取表中的数据 val spark = SparkSession
ZKUtil: ZooKeeper colocation znode : /hadoop/colocationDetails. Will publish colocation details under this znode hierarchy. Create Group is running
【建议】慎用final查询。 在查询语句的最后跟上final，通常是对于ReplacingMergeTree引擎，数据不能完全去重情况下，少数开发人员习惯使用final关键字进行实时合并去重操作（merge-on-read），保证查询数据无重复数据。可以通过argMax函数或其他方式规避此问题。
到table2表 */ public class SparkHbasetoHbase { public static void main(String[] args) throws Exception { SparkConf conf = new SparkConf()
图1 导入样例工程流程 操作步骤 参考获取MRS应用开发样例工程，获取样例代码解压目录中“src”目录下的样例工程文件夹“mapreduce-example-normal”。 导入样例工程到IntelliJ IDEA开发环境。 打开IntelliJ IDEA，依次选择“File
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
