检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
ation为OBS路径，例如： CREATE SCHEMA hive.demo WITH (location = 'obs://mrs-word001/presto-demo002/'); 在该Schema中建表，该表的数据即会存储在OBS文件系统内，例如： CREATE TABLE
如何在CarbonData数据加载时修改默认的组名？ 回答 CarbonData数据加载时，默认的组名为“ficommon”。可以根据需要修改默认的组名。 编辑“carbon.properties”文件。 根据需要修改关键字“carbon.dataload.group.name”的值。其默认值为“ficommon”。
如何在CarbonData数据加载时修改默认的组名？ 回答 CarbonData数据加载时，默认的组名为“ficommon”。可以根据需要修改默认的组名。 编辑“carbon.properties”文件。 根据需要修改关键字“carbon.dataload.group.name”的值。其默认值为“ficommon”。
flatMap { case(line, timestamp) => line.split(" ").map(word => Event(sessionId = word, timestamp))} // Sessionize the events. Track number
flatMap { case(line, timestamp) => line.split(" ").map(word => Event(sessionId = word, timestamp))} // Sessionize the events. Track number
1:28443/web”。 选择“集群 > 待操作集群的名称 > 服务 > Storm”，单击进入Storm WebUI。 在Storm UI中单击word-count应用，查看应用程序运行情况，如图1所示。 图1 Storm应用程序执行界面 Topology stats统计了最近各个不同时间段的算子之间发送数据的总数据量。
1:28443/web”。 选择“集群 > 待操作集群的名称 > 服务 > Storm”，单击进入Storm WebUI。 在Storm UI中单击word-count应用，查看应用程序运行情况，如图1所示。 图1 Storm应用程序执行界面 Topology stats统计了最近各个不同时间段的算子之间发送数据的总数据量。
example.wordcount.WordCountTopology 执行storm list命令，查看已经提交的应用程序，如果发现名称为word-count的应用程序，则说明任务提交成功。 如果业务设置为本地模式，且使用命令行方式提交时，请确保提交环境为普通模式环境，当前不支持安全环境下使用命令提交本地模式的业务。
String[] word = s.split(","); return new Tuple3<>(word[0], word[1], word[2]); }
填写角色的名称，例如opentsdbrole。 编辑角色，在“权限”的表格中选择“HBase> HBase Scope > global”，勾选“Read”、“Write”和“Execute”，单击“确定”保存，如图2所示。 图2 编辑角色 单击“系统设置 > 用户组管理 > 添加
example.wordcount.WordCountTopology。 执行storm list命令，查看已经提交的应用程序，如果发现名称为word-count的应用程序，则说明任务提交成功。 如果业务设置为本地模式，且使用命令行方式提交时，请确保提交环境为普通模式环境，当前不支持安全环境下使用命令提交本地模式的业务。
在Loader页面，单击“新建作业”。 单击“连接”后的下拉列表框，可以查看已创建的连接。 编辑连接 在Loader页面，单击“新建作业”。 单击“连接”后的下拉列表框，选择待编辑的连接名称。 在“连接”后单击“编辑”，进入编辑页面。 根据业务需要，修改连接配置参数。 单击“测试”。 如果显示测试成功，则执行6。
填写角色的名称，例如hbaserole。 编辑角色，在“权限”的表格中选择“HBase> HBase Scope”，勾选“Admin”、“Create”、“Read”、“Write”和“Execute”，单击“确定”保存，如图2所示。 图2 编辑角色 单击“系统设置 > 用户管理 >
登录MRS Manager，在MRS Manager界面选择“系统设置 > 角色管理 > 添加角色”。 填写角色的名称，例如hdfsrole。 编辑角色，在“权限”的表格中选择“HDFS > File System > hdfs://hacluster/”，勾选“Read”、“Writ
分别选择“Policy Name”为“all - job”、“all - link”、“all - driver”、“all - env”的策略，单击按钮编辑策略。 在“Allow Conditions”区域，单击“Select User”下选择框选择用户。 单击“Add Permissions
Yarn的租户队列名。不指定将默认提交到default队列上。 - Description 描述信息。 - 单击“确定”完成ENV创建。 创建完成后可以在“操作”列单击“编辑”进行修改，或者单击“删除”删除该ENV。 父主题： 创建CDL作业前准备
在Loader页面，单击“新建作业”。 单击“连接”后的下拉列表框，可以查看已创建的连接。 编辑连接 在Loader页面，单击“新建作业”。 单击“连接”后的下拉列表框，选择待编辑的连接名称。 在“连接”后单击“编辑”，进入编辑页面。 根据业务需要，修改连接配置参数。 单击“测试”。 如果显示测试成功，则执行6。
登录MRS Manager，在MRS Manager界面选择“系统设置 > 角色管理 > 添加角色”。 填写角色的名称，例如mrrole。 编辑角色，在“权限”的表格中选择“Yarn > Scheduler Queue > root”，勾选“Submit”、“Admin”。 在“权限”表格中选择“HBase
IC)) .withTupleToKafkaMapper( new FieldNameBasedTupleToKafkaMapper("word", "count")); // 定义拓扑 TopologyBuilder builder = new TopologyBuilder();
example.wordcount.WordCountTopology。 执行storm list命令，查看已经提交的应用程序，如果发现名称为word-count的应用程序，则说明任务提交成功。 如果业务设置为本地模式，且使用命令行方式提交时，请确保提交环境为普通模式环境，当前不支持安全环境下使用命令提交本地模式的业务。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
