Shell命令介绍。 开发一个Producer向该Topic生产数据。 开发一个Consumer消费该Topic的数据。 性能调优建议 建议预先创建Topic，根据业务需求合理规划Partition数目，Partition数目限制了消费者的并发数。 消息key值选取一定是可变的，防止由于消息key值不变导致消息分布不均匀。

查看更多 →

Action；如果是Hive，则需要开发SQL文件。 上传配置文件与jar包（包括依赖的jar包）到HDFS，上传的路径取决于“workflow.xml”中的“oozie.wf.application.path”配置的路径。 提供三种方式对工作流进行操作，详情请参见Oozie应用开发常见问题。

查看更多 →

调用fSystem的create接口创建FSDataOutputStream对象：out，使用out的write方法写入数据。 调用fSystem的append接口创建FSDataOutputStream对象：out，使用out的write方法追加写入数据。 调用fSystem的open接

查看更多 →

Kafka样例程序开发思路 场景说明 Kafka是一个分布式消息系统，在此系统上可以做一些消息的发布和订阅操作，假定用户要开发一个Producer，让其每秒向Kafka集群某Topic发送一条消息，另外，还需要实现一个Consumer，订阅该Topic，实时消费该类消息。 开发思路 使用Linux客户端创建一个Topic。

查看更多 →

查看薪水支付币种为美元的雇员联系方式。 查询入职时间为2014年的雇员编号、姓名等字段，并将查询结果加载进表employees_info_extended中的入职时间为2014的分区中。 统计表employees_info中有多少条记录。 查询使用以“cn”结尾的邮箱的员工信息。 提交

查看更多 →

HBase样例程序开发思路 通过典型场景，您可以快速学习和掌握HBase的开发过程，并且对关键的接口函数有所了解。 场景说明 假定用户开发一个应用程序，用于管理企业中的使用A业务的用户信息，如表1所示，A业务操作流程如下： 创建用户信息表。 在用户信息中新增用户的学历、职称等信息。

查看更多 →

扫描任务的得分是如何计算的？ 扫描任务被创建后，初始得分是一百分，任务扫描完成后，根据扫描出的漏洞级别会扣除相应的分数。 网站扫描得分： 高危漏洞，一个扣10分，最多扣60分（6个）。 中危漏洞， 一个扣3分，最多扣45分（15个）。 低危漏洞， 一个扣1分，最多扣30分（30个）。

查看更多 →

如何解决漏洞管理服务中已添加网站的“网站地址”错误的问题？ 开通漏洞管理服务后，首先您需要将网站资产以IP或 域名 的形式添加到漏洞管理服务中并完成网站认证，才能进行漏洞扫描。 将网站添加到漏洞管理服务时，您需要配置网站的地址信息。由于漏洞管理服务中不支持修改网站的地址信息，如果已添

查看更多 →

转码后的视频如何挂载到其它网站？ 转码后的视频存储在指定的输出路径，您可以直接登录OBS控制台查看该文件，挂载到其它文件可参见分享文件。 该方法仅适用视频文件比较小的，若您需要分享的视频过大，建议您使用视频点播服务的OBS托管功能，具体请参见音视频托管。 您也可以通过媒体处理控制台查看转码后的视频文件，步骤如下。

查看更多 →

如何获取桶的静态网站托管地址？ 您可以在控制台的静态网站托管页面上获取到桶的静态网站托管地址。 您也可以拼接桶的静态网站访问地址。拼接地址格式为：https://桶名.静态网站托管域名。 例如区域为“华北-北京四”的桶名为“testbucket”的桶配置成静态网站托管模式后，该桶

查看更多 →

FunctionGraph中的代码是如何隔离的？ 每个FunctionGraph函数都运行在其自己的环境中，有其自己的资源和文件系统。 父主题： 产品咨询

查看更多 →

FlexusRDS的备份是如何收费的 Flexus云数据库RDS的全量备份和增量备份都是存储在OBS上。另外，FlexusRDS for MySQL有100%的赠送空间。举个例子，假如用户购买实例套餐时，规格选择了2U4GB_120GB，那么用户会拥有一个2U4GB的实例、120GB存储空间、120GB

查看更多 →

安装后，会显示在开发环境首页的“项目”页签下。源码包是其他用户开发完应用后，打包编译时选择“源码包”发布出来的应用包。源码包中的所有组件都不受保护和限制，且不能安装自己账号下开发的应用。 在开发环境安装资产包应用。 安装后，会显示在开发环境首页的“库”页签下。资产包是用来在运行环境

查看更多 →

如何对网站进行认证？ 请参考添加网站对网站进行认证。 父主题： 网站扫描类

查看更多 →

conf）。user.keytab和krb5.conf文件为安全模式下的认证文件，需要在 FusionInsight Manager中下载principal用户的认证凭证，样例代码中使用的用户为：sparkuser，需要修改为准备好的开发用户。 打包项目 将user.keytab、krb5.conf

查看更多 →

{partitionNum} topic的分区数。 {replicationNum} topic中每个partition数据的副本数。 {Topic} topic名称。 示例：在Kafka的客户端路径下执行命令，此处以ZooKeeper集群的IP:port是10.96.101.32:2181

查看更多 →

Join样例程序开发思路 场景说明 假定某个Flink业务1每秒就会收到1条消息记录，消息记录某个用户的基本信息，包括名字、性别、年龄。另有一个Flink业务2会不定时收到1条消息记录，消息记录该用户的名字、职业信息。 基于某些业务要求，开发的Flink应用程序实现功能：实时的以根据业

查看更多 →

Flink Hudi样例程序开发思路 本章节适用于 MRS 3.3.0及以后版本。 典型场景说明 本样例中Job每秒生成1条数据，将数据写入到Hudi表中，再读取并打印Hudi表中的数据。 开发思路 写Hudi： 通过一个随机生成数据类来生成数据。 将生成的数据转化为DataStream<RowData>。

查看更多 →

conf）。user.keytab和krb5.conf文件为安全模式下的认证文件，需要在FusionInsight Manager中下载principal用户的认证凭证，样例代码中使用的用户为：sparkuser，需要修改为准备好的开发用户。 打包项目 将user.keytab、krb5.conf

查看更多 →

ClickHouse应用程序开发思路 通过典型场景，用户可以快速学习和掌握ClickHouse的开发过程，并且对关键的接口函数有所了解。 场景说明 ClickHouse可以使用SQL进行常见的业务操作，代码样例中所涉及的SQL操作主要包括创建数据库、创建表、插入表数据、查询表数据以及删除表操作。

查看更多 →

Spark Core样例程序开发思路 场景说明 假定用户有某个周末网民网购停留时间的日志，基于某些业务要求，要求开发Spark应用程序实现如下功能： 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 周末两天的日志文件第一列为姓名，第二列为性别，第三列为本次停留时间，单位为分钟，分隔符为“

查看更多 →