java样例代码 开发说明 mongo只支持增强型跨源。只能使用包年包月队列。 DDS即文档数据库服务，兼容MongoDB协议。 前提条件 在 DLI 管理控制台上已完成创建增强跨源连接，并绑定包年/包月队列。具体操作请参考《 数据湖探索 用户指南》。 认证用的password硬编码到代

查看更多 →

java样例代码 开发说明 本样例只适用于 MRS 的OpenTSDB。 前提条件 在DLI管理控制台上已完成创建跨源连接并绑定队列。具体操作请参考《 数据湖 探索用户指南》。 认证用的password硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全。

查看更多 →

SparkSession; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream;

查看更多 →

Java样例代码 功能简介 在Spark应用中，通过使用HBase接口来实现创建表，读取表，往表中插入数据等操作。 代码样例 下面代码片段仅为演示，具体代码参见SparkOnHbaseJavaExample： 样例：创建HBase表 public class TableCreation

查看更多 →

Java样例代码 功能介绍 用户可以使用Spark调用HBase接口来操作HBase table1表，然后把table1表的数据经过分析后写到HBase table2表中。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

Java样例代码 功能介绍 在Spark应用中，通过使用Streaming调用kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数，或将数据写入Kafka0-10。 Streaming读取Kafka0-10代码样例 下面代码片段仅为演示，具体代码参见：com.huawei

查看更多 →

java样例代码 前提条件 在DLI管理控制台上已完成创建跨源连接。具体操作请参考《数据湖探索用户指南》。 CSS 非安全集群 开发说明 代码实现 构造依赖信息，创建SparkSession 导入依赖 涉及到的mvn依赖库 <dependency> <groupId>org

查看更多 →

登录CDLService WebUI界面 操作场景 MRS集群安装CDL组件后，用户可以通过CDL的图形化界面进行数据连接管理和可视化作业编排等。 本任务指导用户在MRS集群中访问CDL WebUI。 Internet Explorer浏览器可能存在兼容性问题，建议使用Google

查看更多 →

理插件及权限访问控制策略的内容。 User：普通用户，可以被Ranger管理员赋予具体权限。 登录Ranger管理界面 安全模式（集群开启了Kerberos认证） 使用admin用户登录 FusionInsight Manager，具体请参见访问FusionInsight Manager（MRS

查看更多 →

理插件及权限访问控制策略的内容。 User：普通用户，可以被Ranger管理员赋予具体权限。 登录Ranger管理界面 安全模式（集群开启了Kerberos认证） 使用admin用户登录FusionInsight Manager，具体请参见访问集群Manager。选择“集群 > 服务

查看更多 →

使用账号登录时，界面提示“没有权限登录” 在使用OBS Browser+过程中，如果使用账号登录时提示“没有权限登录”，原因是统一身份认证服务平台认证失败。 可按照以下步骤排查解决问题： 联系当前租户的安全管理员，登录统一身份认证服务控制台。 查看当前AK所属用户是否被禁用。 查

查看更多 →

使用账号登录时，界面提示没有权限登录 在使用时空数据专属存储过程中，如果使用账号登录时提示“没有权限登录”，原因是统一身份认证服务平台认证失败。 您可按照以下步骤排查原因、解决问题： 联系当前租户的安全管理员，登录统一身份认证服务控制台。 查看当前AK所属用户是否被禁用。 查看当

查看更多 →

Java语言链代码开发 链代码结构 链代码相关的API 链代码示例 链代码调测 父主题： 链代码开发

查看更多 →

登录OBS Browser时，登录界面无反应 问题 登录客户端时，登录界面无反应。 Windows 32位的OBS Browser更新为Windows 64位的，登录OBS Browser，界面无反应。 回答 请删除C盘用户目录AppData\Local下的obs文件夹以清理OBS

查看更多 →

低代码平台”，即可进入Astro低代码平台。 若当前账号已购买AstroFlow实例，首次登录Astro低代码平台时请设置个人联系方式。如何设置个人联系方式，请参见设置个人联系方式。 图1 编辑个人信息 若当前账号未购买AstroFlow实例，首次登录Astro低代码平台时请通过授权码加入企业。如何加入企业，请参见如何加入/切换企业。

查看更多 →

Flink DataStream Java样例代码 功能简介 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.flink.example.stream.FlinkStreamJavaExample：

查看更多 →

Element; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.security.MessageDigest; import java.time.LocalDateTime;

查看更多 →

+= count; collector.collect(total); } } 应用代码 该段代码是流图定义代码，具体实现业务流程，另外，代码中窗口的触发时间使用了processing time。 1 2 3 4 5 6 7 8 9 10

查看更多 →

界面 设置标题到导航栏 设置导航栏背景和字体颜色 通过type类型设置吐司信息 动态调用并控制loading组件的显示、隐藏 各类异常提示组件 设置水印 父主题： 媒体

查看更多 →

登录Manager时界面报错“认证信息无效” 问题现象 登录MRS集群的Manager界面时，输入用户名及密码信息后登录失败，界面提示“认证信息无效”。 原因分析 当前输入的用户名或密码信息错误。 当前登录用户的密码已过期。 处理步骤 如果用户密码输入错误，请检查并输入正确密码。

查看更多 →

jar，该jar包可在MRS client目录下获取。 代码样例 下面列出producer和consumer，以及Flink Stream SQL Join使用主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafka和com

查看更多 →